My web-application is consuming messages sent by thousands of other publishing applications. I am trying to implement one-queue-per-publishing-application. I want to have a fixed number of inbound-adapters consuming messages from all these queues. Challenge is that these publishing applications get created/destroyed while my web-application is consuming messages. I want to be able to divide the queues available at start-up to the inbound-adapters and then add/remove queues from these adapters while they are consuming messages.