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