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.

Reply via email to