Pattern
Concurrent Polling Race
concurrent-polling-race
the AbstractPollingEndpoint uses a TaskScheduler to schedule a Runnable for the specific period. Tension: This one starts a transaction and tries to pull a message from the mentioned MessageStore. Outcome: those polls might be scheduled in parallel. | those polls might be scheduled in parallel — make this concurrent. Tension: there is no ordering guarantee. | You may look into a PartitionedChannel solution — is not what would fit into transactions. Tension: that would break transaction boundaries. Outcome: You may look into a PartitionedChannel solution.