Skip to content
This repository was archived by the owner on May 4, 2019. It is now read-only.

Commit 3c64a4b

Browse files
author
Alan Scherger
committed
Merge branch 'release/1.6.0'
2 parents b033fd6 + 7573f2f commit 3c64a4b

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

proteus-client/src/main/java/io/netifi/proteus/DefaultProteusBrokerService.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ public DefaultProteusBrokerService(
145145
this.addressSelector = addressSelector;
146146
this.clientTransportFactory = clientTransportFactory;
147147
this.poolSize = poolSize;
148-
this.selectRefresh = poolSize / 2;
148+
this.selectRefresh = poolSize == 1 ? 1 : poolSize / 2;
149149
this.keepalive = keepalive;
150150
this.tickPeriodSeconds = tickPeriodSeconds;
151151
this.ackTimeoutSeconds = ackTimeoutSeconds;
@@ -182,7 +182,10 @@ private void useDiscoveryStrategy() {
182182
discoveryStrategy
183183
.discoverNodes()
184184
.flatMapIterable(Function.identity())
185-
.map(hostAndPort -> new InetSocketAddress(hostAndPort.getHost(), hostAndPort.getPort()))
185+
.map(
186+
hostAndPort ->
187+
InetSocketAddress.createUnresolved(
188+
hostAndPort.getHost(), hostAndPort.getPort()))
186189
.collectList()
187190
.doOnNext(
188191
i -> {

proteus-client/src/main/java/io/netifi/proteus/Proteus.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -707,7 +707,7 @@ public static class Builder {
707707
private int missedAcks = DefaultBuilderConfig.getMissedAcks();
708708
private DiscoveryStrategy discoveryStrategy = null;
709709
private Function<Broker, InetSocketAddress> addressSelector =
710-
BrokerAddressSelectors.BIND_ADDRESS; // Default
710+
BrokerAddressSelectors.TCP_ADDRESS; // Default
711711

712712
private Function<SocketAddress, ClientTransport> clientTransportFactory = null;
713713
private int poolSize = Runtime.getRuntime().availableProcessors() * 2;

proteus-client/src/main/java/io/netifi/proteus/rsocket/transport/BrokerAddressSelectors.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,6 @@
2020
import java.util.function.Function;
2121

2222
public class BrokerAddressSelectors {
23-
24-
public static Function<Broker, InetSocketAddress> BIND_ADDRESS =
25-
broker -> InetSocketAddress.createUnresolved(broker.getIpAddress(), broker.getPort());
2623
public static Function<Broker, InetSocketAddress> TCP_ADDRESS =
2724
broker -> InetSocketAddress.createUnresolved(broker.getTcpAddress(), broker.getTcpPort());
2825
public static Function<Broker, InetSocketAddress> WEBSOCKET_ADDRESS =

proteus-client/src/test/java/io/netifi/proteus/rsocket/transport/WeightedClientTransportSupplierTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public void testShouldDecrementActiveCountOnComplete() {
3838
Broker b = Broker.newBuilder().setTcpAddress("localhost").setTcpPort(8001).build();
3939
WeightedClientTransportSupplier supplier =
4040
new WeightedClientTransportSupplier(
41-
b, BrokerAddressSelectors.BIND_ADDRESS, address -> transport);
41+
b, BrokerAddressSelectors.TCP_ADDRESS, address -> transport);
4242

4343
supplier.select();
4444
DuplexConnection block = supplier.get().connect().block();

0 commit comments

Comments
 (0)