public synchronized void addConsumer ( Consumer consumer , ConsumerConfiguration configuration , int instances ) { for ( int i = 0 ; i < instances ; i ++ ) { this . consumerHolders . add ( new ConsumerHolder ( consumer , configuration ) ) ; } }
Adds a consumer to the container and configures it according to the consumer configuration . Does NOT enable the consumer to consume from the message broker until the container is started .