Functional message_broker_activity_queue_collector()