Commit 696b5647 authored by Gaston Dombiak's avatar Gaston Dombiak Committed by gato

Stop the OutgoingSessionPromise so that new packets are not sent to remote servers. JM-416

git-svn-id: http://svn.igniterealtime.org/svn/repos/messenger/trunk@2890 b35dd754-fafc-0310-a699-88a17e54d16e
parent 029864b6
...@@ -17,6 +17,7 @@ import org.jivesoftware.messenger.container.BasicModule; ...@@ -17,6 +17,7 @@ import org.jivesoftware.messenger.container.BasicModule;
import org.jivesoftware.messenger.handler.PresenceUpdateHandler; import org.jivesoftware.messenger.handler.PresenceUpdateHandler;
import org.jivesoftware.messenger.server.IncomingServerSession; import org.jivesoftware.messenger.server.IncomingServerSession;
import org.jivesoftware.messenger.server.OutgoingServerSession; import org.jivesoftware.messenger.server.OutgoingServerSession;
import org.jivesoftware.messenger.server.OutgoingSessionPromise;
import org.jivesoftware.messenger.spi.BasicStreamIDFactory; import org.jivesoftware.messenger.spi.BasicStreamIDFactory;
import org.jivesoftware.messenger.user.UserManager; import org.jivesoftware.messenger.user.UserManager;
import org.jivesoftware.messenger.user.UserNotFoundException; import org.jivesoftware.messenger.user.UserNotFoundException;
...@@ -1449,6 +1450,8 @@ public class SessionManager extends BasicModule { ...@@ -1449,6 +1450,8 @@ public class SessionManager extends BasicModule {
public void stop() { public void stop() {
Log.debug("Stopping server"); Log.debug("Stopping server");
// Stop threads that are sending packets to remote servers
OutgoingSessionPromise.getInstance().shutdown();
timer.cancel(); timer.cancel();
serverName = null; serverName = null;
if (JiveGlobals.getBooleanProperty("shutdownMessage.enabled")) { if (JiveGlobals.getBooleanProperty("shutdownMessage.enabled")) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment