Added or logic to message_broker_digest_activity_queue_collector()