qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adel Boutros <adelbout...@live.com>
Subject Unroutable messages in Java Qpid Broker 6.0.0
Date Mon, 04 Apr 2016 16:30:38 GMT
Hello,
In the documentation of Qpid Java Broker 6.0.0, it is mentioned here that unroutable messages
will be discarded eventually.
I have a test where a queue is bound to a topic and a message is sent which doesn't match
the binding filter on purpose. Instead of the message being just discarded, the sender is
receiving an error informing him the message was rejected.
Is this expected? shouldn't the sender be "warned" instead of getting an exception?
Another workaround is to implement a "default" queue which will be called from the alternate
exchange but I prefer to check with you this behaviour before implementing the workaround.
Test caseCreate topic "T"Create queue "Q"Create binding between T and Q using a binding key
BK1Have a consumer listen to QHave a sender send to T a message with a binding key BK2
Output client-sidejavax.jms.JMSException: Unknown error from remote peer	at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:125)
at org.apache.qpid.jms.provider.amqp.AmqpFixedProducer.processDeliveryUpdates(AmqpFixedProducer.java:232)
at org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdates(AmqpProvider.java:804)	at
org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1900(AmqpProvider.java:92)	at org.apache.qpid.jms.provider.amqp.AmqpProvider$17.run(AmqpProvider.java:701)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
Checking the code of org.apache.qpid.server.exchange.AbstractExchange#send, when a queue is
not found in the routing table of the Exchange and no alternate exchange is defined, then
the message is considered as org.apache.qpid.amqp_1_0.type.messaging.Rejected. This is what
the org.apache.qpid.amqp_1_0.type.Outcome has as value. Then client side, the code checks
the value of the Outcome and sets an error in case it was rejected.
org.apache.qpid.jms.provider.amqp.AmqpFixedProducer#processDeliveryUpdates} else if (outcome
instanceof Rejected) {
    LOG.trace("Outcome of delivery was rejected: {}", delivery);
    ErrorCondition remoteError = ((Rejected) outcome).getError();
    if (remoteError == null) {
        remoteError = getEndpoint().getRemoteCondition();
    }

    deliveryError = AmqpSupport.convertToException(remoteError);
}
Regards,
Adel Boutroswww.murex.com 		 	   		  
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message