Reworked patch from Avikash Mishra to remove tracked pending acks from a
STOMP subscription that has acked.
(cherry picked from commit 9abbe826ecc47596fb43fd42e094d403c56b158d)
Allow the original exception that triggered the failure to be thrown
from the packet send methods
(cherry picked from commit db8c771b2a37ad16d789f546507b6329221f4c7a)
Configure a value of 128KB for AMQP max frame size by default to improve
overall performance and provide a limit on delivery size before chunking
begins.
(cherry picked from commit b8cfab97db9917cd3f20dc1a9676eef3ac0c999e)
The updated dropMessage method only decrements the destination metrics
if a message is removed from the pagedInMessages list to prevent
duplicate updates. There is also a case where we still need to update
metrics if the message never makes it into the pagedInMessages list in
the first place and that is on expiration so this patch fixes that. A
couple existing tests found this issue.
(cherry picked from commit 6e468b4540754cad5cd30de373cadc026c998669)
Only update metrics counters when message is removed from the
pagedInMessages list which is important to check in case of duplicates
(cherry picked from commit 021c82859cf4361eb31b21fdbac17655ae9e368d)
Need to remove the portion of the test that looks at the dispatched list
for TopicSubscription as that class no longer tracks message references
(cherry picked from commit 84126d8a7a7eb9faf44bef687dcf647e84173f22)
To save memory usage in some use cases add a new flag to PolicyEntry
called useTopicSubscriptionInflightStats to allow disabling the
inflight stats
(cherry picked from commit 65b0f2ad0d48845ad54681ac0eff832de122e2a9)
For the TopicSubscription case we can reduce the inflight statistics
memory footprint by not storing the entire message reference for in
flight messages and instead just a subset of the information needed.
(cherry picked from commit f69fd6f0020290752a7424479821c22d94f9b8b7)
StoreDurableSubscriberCursor now properly uses a timeout value when
attempting to add to the temporary store for non-persistent messages to
prevent an indefinite wait on free space
(cherry picked from commit 5e2adc0ed7dfe2e827bdef878f1c8cde12ff5773)
Update to latest Qpid JMS and Proton-J and the matching netty version
for Qpid JMS 4.1.22.Final
(cherry picked from commit 0bb4a5c3ab43b0f10f4a255f134de5b8533eb67d)
When multiple wildcard policies exist in a hierarchy it was possible for
the wrong policy to be selected when configuring a destination
(cherry picked from commit 2ce1c1352fb64ecf1d3018e2b0f7cabeba99b589)
