Skip to content

Commit 50028bf

Browse files
committed
Updated cluster to 2.6.0-RC1
1 parent ef504cd commit 50028bf

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323

2424
<properties>
2525
<jackson.version>2.11.0</jackson.version>
26-
<scalecube-cluster.version>2.5.0</scalecube-cluster.version>
26+
<scalecube-cluster.version>2.6.0-RC1</scalecube-cluster.version>
2727
<scalecube-commons.version>1.0.4</scalecube-commons.version>
2828
<scalecube-benchmarks.version>1.2.2</scalecube-benchmarks.version>
2929
<scalecube-config.version>0.4.3</scalecube-config.version>

services-discovery/src/main/java/io/scalecube/services/discovery/ScalecubeServiceDiscovery.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import io.scalecube.services.ServiceEndpoint;
1818
import io.scalecube.services.discovery.api.ServiceDiscovery;
1919
import io.scalecube.services.discovery.api.ServiceDiscoveryEvent;
20+
import io.scalecube.transport.netty.websocket.WebsocketTransportFactory;
2021
import java.lang.management.ManagementFactory;
2122
import java.nio.ByteBuffer;
2223
import java.util.List;
@@ -57,8 +58,9 @@ public ScalecubeServiceDiscovery(ServiceEndpoint serviceEndpoint) {
5758
this.serviceEndpoint = Objects.requireNonNull(serviceEndpoint, "serviceEndpoint");
5859
this.clusterConfig =
5960
ClusterConfig.defaultLanConfig()
61+
.metadata(serviceEndpoint)
6062
.memberIdGenerator(serviceEndpoint::id)
61-
.metadata(serviceEndpoint);
63+
.transport(opts -> opts.transportFactory(new WebsocketTransportFactory()));
6264
}
6365

6466
/**

0 commit comments

Comments
 (0)