Permalink
Browse files

Turn off failureCheckAndFlushThread when freezing the connections.

Also remove a duplicate check on "started" at stop().
  • Loading branch information...
Francisco Borges authored and clebertsuconic committed Mar 26, 2013
1 parent 6acabc8 commit 8fcc44bd56b1aab2d476f6b887f30e1ae5037e3d
@@ -278,6 +278,10 @@ public synchronized void allowInvmSecurityOverride(HornetQPrincipal principal)
public synchronized void freeze(final CoreRemotingConnection connectionToKeepOpen)
{
+ if (!started)
+ return;
+ failureCheckAndFlushThread.close(false);
+
for (Acceptor acceptor : acceptors)
{
try
@@ -321,11 +325,6 @@ public void stop(final boolean criticalError) throws Exception
return;
}
- if (!started)
- {
- return;
- }
-
failureCheckAndFlushThread.close(criticalError);
// We need to stop them accepting first so no new connections are accepted after we send the disconnect message

0 comments on commit 8fcc44b

Please sign in to comment.