Design document: https://miro.com/app/board/uXjVNiHIRAE=/?share_link_id=329072158468

Acceptance Criteria

For swatch-contracts:

• The method "pruneUnlistedSubscriptions" from SWATCH-2277 should produce a single message to "platform.rhsm-subscriptions.enabled-orgs-for-tasks" with a message containing the topic name "platform.rhsm-subscriptions.subscription-prune-task".
• The method "syncAllSubscriptions" from SWATCH-2277 should produce a single message to "platform.rhsm-subscriptions.enabled-orgs-for-tasks" with a message containing the topic name "platform.rhsm-subscriptions.subscription-sync-task".
• Create the consumer of "platform.rhsm-subscriptions.subscription-prune-task" that receives a message that includes the orgId. Leave the implementation empty.
• Create the consumer of "platform.rhsm-subscriptions.subscription-sync-task" that receives a message that includes the orgId. Leave the implementation empty.

QE will use this to validate using the mq plugin to read the messages off the queue. 

• We can use app.mq.consumer._find_messages to read messages from a particular topic to validate messages are being produced for certain operations