Hi!
I have SU (servicemix-jms, consumer) witch listens some queue from
external AMQ 5.1.0 (port 61616, and embedded SMX's AMQ 4.1.1 is
configured on pther port) and sends NM to some other SU(servicemix-bean).
For testing I send few messages in a short time (5 messages per 1 second).
I see in AMQ console (http://localhost:8161/admin/queues.jsp): consumer
accepted 1 message, and other messages is redirected to ActiveMQ.DLQ queue.
It is because processing of NM in second SU lasts more than 1 second.
Configuration of by JMS-consumer:
<jms:consumer service="my:Service"
endpoint="endpoint"
targetService="my:Service"
targetInterface="my:Service"
destinationName="my.queue"
connectionFactory="#connectionFactory"
concurrentConsumers="1"
cacheLevel="1"
marshaler="#marshaler" />
<amq:connectionFactory id="connectionFactory"
brokerURL="tcp://localhost:61616" />
Custom marshaller just can accept TextMessage as well as ByteMessage.
I would to disable using of ActiveMQ.DLQ.
Should I change configuration of AMQ 5.1.0?
Or also I should change something in settings of "jms:consumer"?
What policies do exist in my case?
Thanks in advance,
Ivan Pryvalov.