@Test public void testBoundListenerPeersAfterDefaultCacheAdd() throws RemoteException { String[] boundCachePeers = ((RMICacheManagerPeerListener) manager1.getCachePeerListener("RMI")).listBoundRMICachePeers(); assertEquals(1, boundCachePeers.length); validateBoundCachePeer(boundCachePeers); manager1.addCache("fromDefaultCache"); boundCachePeers = ((RMICacheManagerPeerListener) manager1.getCachePeerListener("RMI")).listBoundRMICachePeers(); assertEquals(2, boundCachePeers.length); validateBoundCachePeer(boundCachePeers); }
protected String[] listBoundRMICachePeers() throws CacheException { try { return registry.list(); } catch (RemoteException e) { throw new CacheException("Unable to list cache peers " + e.getMessage()); } }
RMICacheManagerPeerListener implements CacheManagerPeerListener { protected String[] listBoundRMICachePeers() throws CacheException { try { return registry.list(); } catch (RemoteException e) { throw new CacheException("Unable to list cache peers " + e.getMessage()); } } }
RMICacheManagerPeerListener implements CacheManagerPeerListener { protected String[] listBoundRMICachePeers() throws CacheException { try { return registry.list(); } catch (RemoteException e) { throw new CacheException("Unable to list cache peers " + e.getMessage()); } } RMICacheManagerPeerListener(String hostName, Integer port, Integer remoteObjectPort, CacheManager cacheManager,
                                       Integer socketTimeoutMillis); }
RMICacheManagerPeerListener implements CacheManagerPeerListener { protected String[] listBoundRMICachePeers() throws CacheException { try { return registry.list(); } catch (RemoteException e) { throw new CacheException("Unable to list cache peers " + e.getMessage()); } } RMICacheManagerPeerListener(String hostName, Integer port, Integer remoteObjectPort, CacheManager cacheManager,
                                       Integer socketTimeoutMillis); void init(); void dispose(); List getBoundCachePeers(); Status getStatus(); String getUniqueResourceIdentifier(); void attemptResolutionOfUniqueResourceConflict(); String getScheme(); void notifyCacheAdded(String cacheName); void notifyCacheRemoved(String cacheName); }
RMICacheManagerPeerListener implements CacheManagerPeerListener { protected String[] listBoundRMICachePeers() throws CacheException { try { return registry.list(); } catch (RemoteException e) { throw new CacheException("Unable to list cache peers " + e.getMessage()); } } RMICacheManagerPeerListener(String hostName, Integer port, Integer remoteObjectPort, CacheManager cacheManager,
                                       Integer socketTimeoutMillis); void init(); void dispose(); List getBoundCachePeers(); Status getStatus(); String getUniqueResourceIdentifier(); void attemptResolutionOfUniqueResourceConflict(); String getScheme(); void notifyCacheAdded(String cacheName); void notifyCacheRemoved(String cacheName);  }