This repository was archived by the owner on May 4, 2019. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +17
-4
lines changed
proteus-client/src/main/java/io/netifi/proteus/rsocket/transport Expand file tree Collapse file tree 1 file changed +17
-4
lines changed Original file line number Diff line number Diff line change 1818import io .netifi .proteus .broker .info .Broker ;
1919import java .net .InetSocketAddress ;
2020import java .util .function .Function ;
21+ import org .slf4j .Logger ;
22+ import org .slf4j .LoggerFactory ;
2123
2224public class BrokerAddressSelectors {
25+ private static final Logger logger = LoggerFactory .getLogger (BrokerAddressSelectors .class );
26+
2327 public static Function <Broker , InetSocketAddress > TCP_ADDRESS =
24- broker -> InetSocketAddress .createUnresolved (broker .getTcpAddress (), broker .getTcpPort ());
28+ broker -> {
29+ logger .debug (
30+ "using tcp info: host={} port={}" , broker .getTcpAddress (), broker .getTcpPort ());
31+ return InetSocketAddress .createUnresolved (broker .getTcpAddress (), broker .getTcpPort ());
32+ };
2533 public static Function <Broker , InetSocketAddress > WEBSOCKET_ADDRESS =
26- broker ->
27- InetSocketAddress .createUnresolved (
28- broker .getWebSocketAddress (), broker .getWebSocketPort ());
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+ };
2942}
You can’t perform that action at this time.
0 commit comments