We also need to solve a multi-cluster environment, where a single cluster consumes a message and other clusters cannot consume queue messages.
We also need to solve a multi-cluster environment, where a single cluster consumes a message and other clusters cannot consume queue messages.