@Test public void discard() throws Exception { }
@Override public void discard(ServerInfo serverInfo, Channel channel) { ServerPool serverPool = serverPoolMap.get(serverInfo); if (serverPool == null) { return; } serverPool.discard(channel); }
PoolingChannelPool implements ChannelPool { @Override public void discard(ServerInfo serverInfo, Channel channel) { ServerPool serverPool = serverPoolMap.get(serverInfo); if (serverPool == null) { return; } serverPool.discard(channel); } }
PoolingChannelPool implements ChannelPool { @Override public void discard(ServerInfo serverInfo, Channel channel) { ServerPool serverPool = serverPoolMap.get(serverInfo); if (serverPool == null) { return; } serverPool.discard(channel); } PoolingChannelPool(final Timer cleanupTimer, TimeProvider timeProvider, long timeoutInMilliseconds, final MetricCallback metricCallback); }
PoolingChannelPool implements ChannelPool { @Override public void discard(ServerInfo serverInfo, Channel channel) { ServerPool serverPool = serverPoolMap.get(serverInfo); if (serverPool == null) { return; } serverPool.discard(channel); } PoolingChannelPool(final Timer cleanupTimer, TimeProvider timeProvider, long timeoutInMilliseconds, final MetricCallback metricCallback); @Override Channel get(ServerInfo serverInfo); @Override void offer(ServerInfo serverInfo, Channel channel); @Override void discard(ServerInfo serverInfo, Channel channel); @Override boolean isActive(); @Override void shutdown(); }
PoolingChannelPool implements ChannelPool { @Override public void discard(ServerInfo serverInfo, Channel channel) { ServerPool serverPool = serverPoolMap.get(serverInfo); if (serverPool == null) { return; } serverPool.discard(channel); } PoolingChannelPool(final Timer cleanupTimer, TimeProvider timeProvider, long timeoutInMilliseconds, final MetricCallback metricCallback); @Override Channel get(ServerInfo serverInfo); @Override void offer(ServerInfo serverInfo, Channel channel); @Override void discard(ServerInfo serverInfo, Channel channel); @Override boolean isActive(); @Override void shutdown();  }