BlockingChannelConnector.java | 61 private final Set<BlockingChannelEndPoint> _endpoints = new ConcurrentHashSet<BlockingChannelEndPoint>(); field in class:BlockingChannelConnector 97 for (BlockingChannelEndPoint endp : _endpoints) 274 _endpoints.add(this); 323 _endpoints.remove(this);
|