protected final void registerConsumer ( AbstractMessageConsumer consumer ) { if ( consumersMap . put ( consumer . getId ( ) , consumer ) != null ) throw new IllegalArgumentException ( "Consumer " + consumer . getId ( ) + " already exists" ) ; }
Register a consumer