@Test public void test_share_connect(){ init(0); Assert.assertEquals(demoClient.getLocalAddress(), helloClient.getLocalAddress()); Assert.assertEquals(demoClient, helloClient); destoy(); }
public InetSocketAddress getLocalAddress() { return client.getLocalAddress(); }
ReferenceCountExchangeClient implements ExchangeClient { public InetSocketAddress getLocalAddress() { return client.getLocalAddress(); } }
ReferenceCountExchangeClient implements ExchangeClient { public InetSocketAddress getLocalAddress() { return client.getLocalAddress(); } ReferenceCountExchangeClient(ExchangeClient client, ConcurrentMap<String, LazyConnectExchangeClient> ghostClientMap); }
ReferenceCountExchangeClient implements ExchangeClient { public InetSocketAddress getLocalAddress() { return client.getLocalAddress(); } ReferenceCountExchangeClient(ExchangeClient client, ConcurrentMap<String, LazyConnectExchangeClient> ghostClientMap); void reset(URL url); ResponseFuture request(Object request); URL getUrl(); InetSocketAddress getRemoteAddress(); ChannelHandler getChannelHandler(); ResponseFuture request(Object request, int timeout); boolean isConnected(); void reconnect(); InetSocketAddress getLocalAddress(); boolean hasAttribute(String key); void reset(Parameters parameters); void send(Object message); ExchangeHandler getExchangeHandler(); Object getAttribute(String key); void send(Object message, boolean sent); void setAttribute(String key, Object value); void removeAttribute(String key); void close(); void close(int timeout); boolean isClosed(); void incrementAndGetCount(); }
ReferenceCountExchangeClient implements ExchangeClient { public InetSocketAddress getLocalAddress() { return client.getLocalAddress(); } ReferenceCountExchangeClient(ExchangeClient client, ConcurrentMap<String, LazyConnectExchangeClient> ghostClientMap); void reset(URL url); ResponseFuture request(Object request); URL getUrl(); InetSocketAddress getRemoteAddress(); ChannelHandler getChannelHandler(); ResponseFuture request(Object request, int timeout); boolean isConnected(); void reconnect(); InetSocketAddress getLocalAddress(); boolean hasAttribute(String key); void reset(Parameters parameters); void send(Object message); ExchangeHandler getExchangeHandler(); Object getAttribute(String key); void send(Object message, boolean sent); void setAttribute(String key, Object value); void removeAttribute(String key); void close(); void close(int timeout); boolean isClosed(); void incrementAndGetCount();  }