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

Commit 06b7b92

Browse files
author
Alan Scherger
committed
feat: remove logging; formatting
1 parent a28c6bd commit 06b7b92

File tree

2 files changed

+5
-14
lines changed

2 files changed

+5
-14
lines changed

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

Lines changed: 1 addition & 1 deletion
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 == 1 ? 1 : poolSize/ 2;
148+
this.selectRefresh = poolSize == 1 ? 1 : poolSize / 2;
149149
this.keepalive = keepalive;
150150
this.tickPeriodSeconds = tickPeriodSeconds;
151151
this.ackTimeoutSeconds = ackTimeoutSeconds;

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

Lines changed: 4 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -25,18 +25,9 @@ public class BrokerAddressSelectors {
2525
private static final Logger logger = LoggerFactory.getLogger(BrokerAddressSelectors.class);
2626

2727
public static Function<Broker, InetSocketAddress> TCP_ADDRESS =
28-
broker -> {
29-
logger.debug(
30-
"using tcp info: host={} port={}", broker.getTcpAddress(), broker.getTcpPort());
31-
return InetSocketAddress.createUnresolved(broker.getTcpAddress(), broker.getTcpPort());
32-
};
28+
broker -> InetSocketAddress.createUnresolved(broker.getTcpAddress(), broker.getTcpPort());
3329
public static Function<Broker, InetSocketAddress> WEBSOCKET_ADDRESS =
34-
broker -> {
35-
logger.debug(
36-
"using websocket info: host={} port={}",
37-
broker.getWebSocketAddress(),
38-
broker.getWebSocketPort());
39-
return InetSocketAddress.createUnresolved(
40-
broker.getWebSocketAddress(), broker.getWebSocketPort());
41-
};
30+
broker ->
31+
InetSocketAddress.createUnresolved(
32+
broker.getWebSocketAddress(), broker.getWebSocketPort());
4233
}

0 commit comments

Comments
 (0)