private void connected ( final MemcachedNode node ) { assert node . getChannel ( ) . isConnected ( ) : "Not connected." ; int rt = node . getReconnectCount ( ) ; node . connected ( ) ; for ( ConnectionObserver observer : connObservers ) { observer . connectionEstablished ( node . getSocketAddress ( ) , rt ) ; } }
Indicate a successful connect to the given node .