diff --git a/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/messaging/ReconnectingChannel.java b/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/messaging/ReconnectingChannel.java index a52f220c962d3..3254fe57cfc94 100644 --- a/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/messaging/ReconnectingChannel.java +++ b/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/messaging/ReconnectingChannel.java @@ -23,7 +23,6 @@ import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFutureListener; import io.netty.channel.EventLoop; -import io.netty.util.Attribute; import io.netty.util.AttributeKey; import io.netty.util.concurrent.Promise; @@ -95,7 +94,9 @@ else if ( fChannel != null && !fChannel.isDone() ) { if ( !f.isSuccess() ) { - f.channel().eventLoop().schedule( this::tryConnect, connectionBackoff.getMillis(), MILLISECONDS ); + long millis = connectionBackoff.getMillis(); + log.warn( "Failed to connect to: %s. Retrying in %d ms", destination.socketAddress(), millis ); + f.channel().eventLoop().schedule( this::tryConnect, millis, MILLISECONDS ); connectionBackoff.increment(); } else diff --git a/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/net/Server.java b/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/net/Server.java index fcce7ffda5f16..094e4ec8f925d 100644 --- a/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/net/Server.java +++ b/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/net/Server.java @@ -99,6 +99,7 @@ public synchronized void start() try { channel = bootstrap.bind().syncUninterruptibly().channel(); + debugLog.info( serverName + ": bound to " + listenAddress ); } catch ( Exception e ) {