I think you need a pendngMessageLimitStrategy that sets pending
messages limit to 0 so that the broker does not keep messages past the
prefetch value.
Once a slow consumers prefetch buffer is filled, messages will be
discarded. Reducing the prefetch value (which will effect latency)
could ensure th
We have AMQ client applications in C++ that only use topics, and for which
latency is more important than guaranteed delivery. If messages were
persisted in a database for a significant amount of time before they were
consumed by a slow consumer, that would introduce problems of the same
magnitude
