Terminate processor on shutdown.
This commit is contained in:
@@ -938,4 +938,9 @@ public class ProtocolProcessor {
|
||||
public ISessionsStore getSessionsStore() {
|
||||
return m_sessionsStore;
|
||||
}
|
||||
|
||||
public void shutdown() {
|
||||
if (m_interceptor != null)
|
||||
m_interceptor.stop();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -254,8 +254,8 @@ public class ProtocolProcessorBootstrapper {
|
||||
public void shutdown() {
|
||||
if (storeShutdown != null)
|
||||
storeShutdown.run();
|
||||
// if (m_interceptor != null)
|
||||
// m_interceptor.stop();
|
||||
if (m_processor != null)
|
||||
m_processor.shutdown();
|
||||
}
|
||||
|
||||
public ConnectionDescriptorStore getConnectionDescriptors() {
|
||||
|
||||
Reference in New Issue
Block a user