Added exposeAddress TransportConfig setting

Author: artem-v

cluster/src/main/java/io/scalecube/cluster/ClusterImpl.java

@@ -376,17 +376,21 @@ private Member createLocalMember(Address address) {
     final int port = address.port();
     final List<Address> memberAddresses = new ArrayList<>();
 
-    // First address comes as "fair" listen address
-    memberAddresses.add(address);
+    if (config.transportConfig().exposeAddress()) {
+      memberAddresses.add(address);
+    }
 
-    // Tail goes as externalHosts, if exists
     final List<String> externalHosts = config.externalHosts();
     if (externalHosts != null) {
       for (String externalHost : externalHosts) {
         memberAddresses.add(Address.create(externalHost, port));
       }
     }
 
+    if (memberAddresses.isEmpty()) {
+      throw new IllegalArgumentException("Member addresses must not be empty");
+    }
+
     final String memberId =
         config.memberId() != null ? config.memberId() : UUID.randomUUID().toString();
     final String memberAlias = config.memberAlias();

transport-parent/transport-api/src/main/java/io/scalecube/cluster/transport/api/TransportConfig.java

@@ -23,6 +23,7 @@ public final class TransportConfig implements Cloneable {
   private int maxFrameLength = 2 * 1024 * 1024; // 2 MB
   private TransportFactory transportFactory;
   private Function<Address, Address> addressMapper = Function.identity();
+  private boolean exposeAddress = true;
 
   public TransportConfig() {}
 
@@ -73,7 +74,7 @@ public TransportConfig port(int port) {
     return t;
   }
 
-  public boolean isClientSecured() {
+  public boolean clientSecured() {
     return clientSecured;
   }
 
@@ -137,35 +138,52 @@ public TransportConfig maxFrameLength(int maxFrameLength) {
     return t;
   }
 
+  public TransportFactory transportFactory() {
+    return transportFactory;
+  }
+
   /**
-   * Setter for {@code addressMapper}.
+   * Setter for {@code transportFactory}.
    *
-   * @param addressMapper address mapper
+   * @param transportFactory transport factory
    * @return new {@code TransportConfig} instance
    */
-  public TransportConfig addressMapper(Function<Address, Address> addressMapper) {
+  public TransportConfig transportFactory(TransportFactory transportFactory) {
     TransportConfig t = clone();
-    t.addressMapper = addressMapper;
+    t.transportFactory = transportFactory;
     return t;
   }
 
   public Function<Address, Address> addressMapper() {
     return addressMapper;
   }
 
-  public TransportFactory transportFactory() {
-    return transportFactory;
+  /**
+   * Setter for {@code addressMapper}.
+   *
+   * @param addressMapper address mapper
+   * @return new {@code TransportConfig} instance
+   */
+  public TransportConfig addressMapper(Function<Address, Address> addressMapper) {
+    TransportConfig t = clone();
+    t.addressMapper = addressMapper;
+    return t;
+  }
+
+  public boolean exposeAddress() {
+    return exposeAddress;
   }
 
   /**
-   * Setter for {@code transportFactory}.
+   * Setter for {@code exposeAddress}. When set to {@code true} - will make transport listening
+   * address be advertised to cluster. By default set to {@code true}.
    *
-   * @param transportFactory transport factory
+   * @param exposeAddress exposeAddress flag
    * @return new {@code TransportConfig} instance
    */
-  public TransportConfig transportFactory(TransportFactory transportFactory) {
+  public TransportConfig exposeAddress(boolean exposeAddress) {
     TransportConfig t = clone();
-    t.transportFactory = transportFactory;
+    t.exposeAddress = exposeAddress;
     return t;
   }
 
@@ -188,6 +206,7 @@ public String toString() {
         .add("maxFrameLength=" + maxFrameLength)
         .add("transportFactory=" + transportFactory)
         .add("addressMapper=" + addressMapper)
+        .add("exposeAddress=" + exposeAddress)
         .toString();
   }
 }

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/tcp/TcpSender.java

@@ -52,6 +52,6 @@ private TcpClient newTcpClient(SenderContext context, Address address) {
                 (connectionObserver, channel, remoteAddress) ->
                     new TcpChannelInitializer(config.maxFrameLength())
                         .accept(connectionObserver, channel));
-    return config.isClientSecured() ? tcpClient.secure() : tcpClient;
+    return config.clientSecured() ? tcpClient.secure() : tcpClient;
   }
 }

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/websocket/WebsocketSender.java

@@ -55,7 +55,7 @@ private HttpClient.WebsocketSender newWebsocketSender(SenderContext context, Add
             .option(ChannelOption.SO_REUSEADDR, true)
             .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, config.connectTimeout());
 
-    if (config.isClientSecured()) {
+    if (config.clientSecured()) {
       httpClient = httpClient.secure();
     }