This closes #416
This commit is contained in:
commit
4fb51eff1d
|
@ -256,9 +256,9 @@ public class ReconnectTest extends ActiveMQTestBase {
|
|||
|
||||
@Override
|
||||
public void beforeReconnect(ActiveMQException exception) {
|
||||
latchCommit.countDown();
|
||||
threadToBeInterrupted.add(Thread.currentThread());
|
||||
System.out.println("Thread " + Thread.currentThread() + " reconnecting now");
|
||||
latchCommit.countDown();
|
||||
}
|
||||
});
|
||||
|
||||
|
|
Loading…
Reference in New Issue