Loading...

XML

Word

Printable

Including all the classes under the package “org.candlepin.subscriptions.subscription”
Including the Kafka configuration and tests
Test using /internal/subscriptions/sync/org/{org_id}:
- org.candlepin.subscriptions.subscription.SubscriptionSyncController#forceSyncSubscriptionsForOrgAsync
- And also kafka via org.candlepin.subscriptions.subscription.SubscriptionWorker#receive(org.candlepin.subscriptions.subscription.SyncSubscriptionsTask, org.springframework.kafka.support.Acknowledgment)
The rest endpoint in swatch-contracts should be /internal/rpc/subscriptions/sync/org/{org_id} to match the general structure of other swatch-contracts internal API endpoints.
An unleash feature flag should be used to determine whether the kafka processing is enabled in swatch-subscription-sync or swatch-contracts
Update the methods that were left empty in ~~SWATCH-2276~~ to use the correct ones

depends on

SWATCH-2276 Expose the OrgConfigRepository.findSyncEnabledOrgs via Kafka topics

SWATCH-2278 Port the product deny list configuration to swatch-contracts

SWATCH-2356 Produce request to platform.rhsm-subscriptions.enabled-orgs-for-tasks for prune and sync all tasks in swatch-contracts

is blocked by

SWATCH-2279 Port CapacityReconciliationController to swatch-contracts

SWATCH-2280 Port OfferingSyncController and part of SubscriptionSyncController to swatch-contracts

is depended on by

SWATCH-2282 Port logic of Subscription Sync API from the monolith to swatch-contracts

SWATCH-2292 Port SubscriptionWorker.receive (JmsListener) to SubscriptionCanonicalMessageConsumer.receive in swatch-contracts

SWATCH-2294 Port SubscriptionWorker.receive (KafkaListener) to swatch-contracts

(3 is depended on by)