public void stop ( ) { instanceLock . writeLock ( ) . lock ( ) ; try { for ( final NamespaceChangeStreamListener streamer : nsStreamers . values ( ) ) { streamer . stop ( ) ; } } finally { instanceLock . writeLock ( ) . unlock ( ) ; } }
Stops all streams .