diff --git a/core/src/main/java/org/bitcoinj/core/Peer.java b/core/src/main/java/org/bitcoinj/core/Peer.java index 137a209d..56ec4322 100644 --- a/core/src/main/java/org/bitcoinj/core/Peer.java +++ b/core/src/main/java/org/bitcoinj/core/Peer.java @@ -276,6 +276,14 @@ public class Peer extends PeerSocketHandler { } } + @Override + protected void timeoutOccurred() { + super.timeoutOccurred(); + if (!connectionOpenFuture.isDone()) { + connectionClosed(); // Invoke the event handlers to tell listeners e.g. PeerGroup that we never managed to connect. + } + } + @Override public void connectionClosed() { for (final PeerListenerRegistration registration : eventListeners) {