diff --git a/core/src/main/groovy/com/muwire/core/connection/Connection.groovy b/core/src/main/groovy/com/muwire/core/connection/Connection.groovy
index 9096d808..0dad76b6 100644
--- a/core/src/main/groovy/com/muwire/core/connection/Connection.groovy
+++ b/core/src/main/groovy/com/muwire/core/connection/Connection.groovy
@@ -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))
     }