activemq
activemq copied to clipboard
[AMQ-8354] Add helper methods needed for replica plugin.
AMQ-8354
extracted internal changes from https://github.com/apache/activemq/pull/848 to make it easier to review.
Added some new methods that will be used only in replica plugin.
Updated processDispatchNotification and related methods to work correctly(it's not been used since pure master-slave feature was deleted). it will also be used in the plugin
List of changes:
- made
ConnectionContext#setUserNameto be able to differentiate replication context(the context we use to interact with the broker) from every other to prevent replication of replicated events. ( shouldn't impact the broker) - added
queuePurgedmethod to notify about a queue being purged. needed for queue purge replication. (new method, it shouldn't impact the broker anyhow) - added
getDispatchedmethod to be able to fetch the list of message we are acknowledging, so we can correctly replicate acks(new method, it shouldn't impact the broker anyhow) - added
getMatchingMessagesmethod to be able to get messages by selector when the consumer is full. needed for message compaction(new method, it shouldn't impact the broker anyhow) - changes in
processDispatchNotification,getMatchingMessageandprocessMessageDispatchNotificationto be able to replicate acks correctly. basically a bug fix. (it's not been used since pure master-slave feature was deleted. it shouldn't impact the broker anyhow)