[ARTEMIS] Message not being consumed from queue which came from topic using divert and selector expression

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

[ARTEMIS] Message not being consumed from queue which came from topic using divert and selector expression

Archibald
This post was updated on .
Hi all, I stumbled on an issue which looks similar to ARTEMIS-1508 <https://issues.apache.org/jira/browse/ARTEMIS-1508> using version 2.4.0. The setup is the very same: A is used to route messages from a topic to a queue, and a consumer is attached to the target queue using a selector expression. Message is not being consumed and broker log reads:
12:22:35,327 ERROR [org.apache.activemq.artemis.core.server] AMQ224006: Invalid filter: eventName  = 'XXXEvent': org.apache.qpid.proton.codec.DecodeException: Unknown constructor
        at org.apache.qpid.proton.codec.DecoderImpl.readObject(DecoderImpl.java:883) [proton-j-0.22.0.jar:]
        at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getApplicationProperties(AMQPMessage.java:179) [artemis-amqp-protocol-2.4.0.jar:]
        at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getApplicationPropertiesMap(AMQPMessage.java:157) [artemis-amqp-protocol-2.4.0.jar:]
        at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getObjectProperty(AMQPMessage.java:916) [artemis-amqp-protocol-2.4.0.jar:]
        at org.apache.activemq.artemis.core.filter.impl.FilterImpl$FilterableServerMessage.getProperty(FilterImpl.java:196) [artemis-server-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.selector.filter.PropertyExpression.evaluate(PropertyExpression.java:34) [artemis-selector-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.selector.filter.ComparisonExpression$1.evaluate(ComparisonExpression.java:219) [artemis-selector-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.selector.filter.ComparisonExpression.matches(ComparisonExpression.java:493) [artemis-selector-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.core.filter.impl.FilterImpl.match(FilterImpl.java:105) [artemis-server-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.handle(ServerConsumerImpl.java:388) [artemis-server-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.handle(QueueImpl.java:2804) [artemis-server-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2189) [artemis-server-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1900(QueueImpl.java:105) [artemis-server-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2996) [artemis-server-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.4.0.jar:2.4.0]
        at org.apache.activemq.artemis.utils.actors.ProcessorBase$ExecutorTask.run(ProcessorBase.java:53) [artemis-commons-2.4.0.jar:2.4.0]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_151]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_151]
        at java.lang.Thread.run(Thread.java:748) [rt.jar:1.8.0_151]
Any help on this? Thanks, Archibald -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Reply | Threaded
Open this post in threaded view
|

Re: [ARTEMIS] Message not being consumed from queue which came from topic using divert and selector expression

Archibald
The issue occurs only, if the original message is being sent via AMQP (the
receiver itself is a JMS-Consumer). If I use a JMS Producer everything works
as expected.

Br, Archibald



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Reply | Threaded
Open this post in threaded view
|

Re: [ARTEMIS] Message not being consumed from queue which came from topic using divert and selector expression

jbertram
Based on your description I'd say it's the same issue.  A fix was committed
to the code-base on November 27 so it's not in any release yet (2.4.0 was
released on November 7).  You can try building from master and testing if
you like otherwise I guess you'll need to wait until 2.5.0 is released.


Justin

On Fri, Jan 12, 2018 at 1:51 AM, Archibald <[hidden email]> wrote:

> The issue occurs only, if the original message is being sent via AMQP (the
> receiver itself is a JMS-Consumer). If I use a JMS Producer everything
> works
> as expected.
>
> Br, Archibald
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> f2341805.html
>
Reply | Threaded
Open this post in threaded view
|

Re: [ARTEMIS] Message not being consumed from queue which came from topic using divert and selector expression

Archibald
Thanks Justin,

with the fix in ARTEMIS-1508 the issue is also gone for in my case.

Br, Archibald



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html