clebertsuconic commented on a change in pull request #2695: ARTEMIS-2372
Filtering on Message Annotations
URL: https://github.com/apache/activemq-artemis/pull/2695#discussion_r290933530
##########
File path:
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
##########
@@ -1263,7 +1263,10 @@ public Long getLongProperty(String key) throws
ActiveMQPropertyConversionExcepti
@Override
public Object getObjectProperty(String key) {
- if (key.equals(MessageUtil.TYPE_HEADER_NAME.toString())) {
+
+ if
(key.startsWith(AMQPMessageSupport.JMS_AMQP_MESSAGE_ANNOTATION_PREFIX)) {
Review comment:
@tabish121 what UnsignedLong keys? This is getObjectProperty().
This is about filtering. The issue is when moving a message to DLQ, the copy
will apply a message annotation.
Previously with AMQ5, users would be able to filter by
JMS_AMQP_MA_ORIG_QUEUE. This is just bringing that possibility.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
