Skip to content

Commit

Permalink
Rename cluster_listen_address to discovery_listen_address.
Browse files Browse the repository at this point in the history
  • Loading branch information
apcj committed Aug 10, 2016
1 parent 3c7ee6b commit 77c326a
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
Expand Up @@ -138,8 +138,8 @@ public String toString()
setting( "core_edge.raft_advertised_address", ADVERTISED_SOCKET_ADDRESS, "localhost:7000" );

@Description("Host and port to bind the cluster management communication.")
public static final Setting<ListenSocketAddress> hazelcast_listen_address =
setting( "core_edge.hazelcast_listen_address", LISTEN_SOCKET_ADDRESS, "0.0.0.0:5000" );
public static final Setting<ListenSocketAddress> discovery_listen_address =
setting( "core_edge.discovery_listen_address", LISTEN_SOCKET_ADDRESS, "0.0.0.0:5000" );

@Description("A comma-separated list of other members of the cluster to join.")
public static final Setting<List<AdvertisedSocketAddress>> initial_core_cluster_members =
Expand Down
Expand Up @@ -103,7 +103,7 @@ private HazelcastInstance createHazelcastInstance()
log.info( "Discovering cluster with initial members: " + initialMembers );

NetworkConfig networkConfig = new NetworkConfig();
ListenSocketAddress hazelcastAddress = config.get( CoreEdgeClusterSettings.hazelcast_listen_address );
ListenSocketAddress hazelcastAddress = config.get( CoreEdgeClusterSettings.discovery_listen_address );
networkConfig.setPort( hazelcastAddress.socketAddress().getPort() );
networkConfig.setJoin( joinConfig );

Expand Down
Expand Up @@ -77,7 +77,7 @@ public CoreClusterMember( int serverId, int clusterSize,
params.put( CoreEdgeClusterSettings.cluster_name.name(), CLUSTER_NAME );
params.put( CoreEdgeClusterSettings.initial_core_cluster_members.name(), initialMembers );
params.put( GraphDatabaseSettings.record_format.name(), recordFormat );
params.put( CoreEdgeClusterSettings.hazelcast_listen_address.name(), "localhost:" + clusterPort );
params.put( CoreEdgeClusterSettings.discovery_listen_address.name(), "localhost:" + clusterPort );
params.put( CoreEdgeClusterSettings.transaction_advertised_address.name(), "localhost:" + txPort );
params.put( CoreEdgeClusterSettings.transaction_listen_address.name(), "127.0.0.1:" + txPort );
params.put( CoreEdgeClusterSettings.raft_advertised_address.name(), "localhost:" + raftPort );
Expand Down

0 comments on commit 77c326a

Please sign in to comment.