wait less time for reset()

This commit is contained in:
Zlatin Balevsky
2019-10-29 09:35:57 +00:00
parent d7c7afe2c0
commit f69727ab43

View File

@@ -105,7 +105,7 @@ abstract class Connection implements Closeable {
latch.countDown()
log.info("closed $name")
})
latch.await(3000, TimeUnit.MILLISECONDS)
latch.await(1000, TimeUnit.MILLISECONDS)
eventBus.publish(new DisconnectionEvent(destination: endpoint.destination))
}