public void registerConsumer ( LocalMessageConsumer consumer ) { consumersLock . writeLock ( ) . lock ( ) ; try { localConsumers . add ( consumer ) ; } finally { consumersLock . writeLock ( ) . unlock ( ) ; } }
Register a message consumer on this queue