Log connection info to help identify configuration issues.

neo4j · Feb 8, 2017 · afaa7e1 · afaa7e1
1 parent e76545e
commit afaa7e1
Showing 1 changed file with 20 additions and 2 deletions.
diff --git a/...ring/src/main/java/org/neo4j/causalclustering/discovery/HazelcastCoreTopologyService.java b/...ring/src/main/java/org/neo4j/causalclustering/discovery/HazelcastCoreTopologyService.java
@@ -159,7 +159,6 @@ private HazelcastInstance createHazelcastInstance()
         {
             tcpIpConfig.addMember( address.toString() );
         }
-        log.info( "Discovering cluster with initial members: " + initialMembers );
 
         Setting<ListenSocketAddress> discovery_listen_address = CausalClusteringSettings.discovery_listen_address;
         ListenSocketAddress hazelcastAddress = config.get( discovery_listen_address );
@@ -185,7 +184,7 @@ private HazelcastInstance createHazelcastInstance()
         MemberAttributeConfig memberAttributeConfig = HazelcastClusterTopology.buildMemberAttributes( myself, config );
 
         c.setMemberAttributeConfig( memberAttributeConfig );
-        userLog.info( "Waiting for other members to join cluster before continuing..." );
+        logConnectionInfo( initialMembers );
 
         DelayedLog delayedLog = new DelayedLog( "The server has not been able to connect in a timely fashion to the " +
                 "cluster. Please consult the logs for more details. Rebooting the server may solve the problem", log );
@@ -212,6 +211,25 @@ private HazelcastInstance createHazelcastInstance()
         return hazelcastInstance;
     }
 
+    private void logConnectionInfo( List<AdvertisedSocketAddress> initialMembers )
+    {
+        userLog.info(   "My connection info: " +
+                        "[\n\tDiscovery:   listen=%s, advertised=%s," +
+                        "\n\tTransaction: listen=%s, advertised=%s, " +
+                        "\n\tRaft:        listen=%s, advertised=%s, " +
+                        "\n\tClient Connector Addresses: %s" +
+                        "\n]",
+                config.get( CausalClusteringSettings.discovery_listen_address ),
+                config.get( CausalClusteringSettings.discovery_advertised_address ),
+                config.get( CausalClusteringSettings.transaction_listen_address ),
+                config.get( CausalClusteringSettings.transaction_advertised_address ),
+                config.get( CausalClusteringSettings.raft_listen_address ),
+                config.get( CausalClusteringSettings.raft_advertised_address ),
+                ClientConnectorAddresses.extractFromConfig( config ) );
+        userLog.info( "Discovering cluster with initial members: " + initialMembers );
+        userLog.info( "Attempting to connect to the other cluster members before continuing..." );
+    }
+
     private Integer minimumClusterSizeThatCanTolerateOneFaultForExpectedClusterSize()
     {
         return config.get( CausalClusteringSettings.expected_core_cluster_size ) / 2 + 1;