You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Andreas Lanzl <an...@klipp.at> on 2023/09/13 09:01:27 UTC
messages not moved to DLQ
Hi all.
I'm trying to test the DLQ function in artemis V 2.30.0 but i can't get it working. My setup is like so:
running artemis inside docker container with default configuration. According to the docs the
max-delivery-attempts is by default 10. below is a little test programm written in java using the core client to connect to artemis. this test program creates a queue and sends one message and then consumes this message and rollback every consume. the issue is now that the message is received over and over again and not moved to the DLQ after 10 transmits. I also tried to set the max-delivery-attempts setting in broker.xml but this does not work either. (i have to mention that core client version is 2.19.1 due i use java 8)
pls someone can point me in the right direction.. thx. -andreas
ServerLocator locator = ActiveMQClient.createServerLocator("tcp://localhost:61616");
ClientSessionFactory factory = locator.createSessionFactory();
ClientSession session = factory.createSession("artemis","artemis1234",false,false,false,false,1);
session.createAddress(new SimpleString("test"), RoutingType.MULTICAST, false);
QueueConfiguration configuration = new QueueConfiguration("queue");
configuration.setAddress("test");
session.createQueue(configuration);
ClientProducer producer = session.createProducer("test");
ClientMessage message = session.createMessage(true);
message.putStringProperty("text","test");
producer.send(message);
session.commit();
session.start();
ClientConsumer consumer = session.createConsumer("queue");
while(true)
{
System.out.println("waiting for message");
ClientMessage rec = consumer.receive(5000);
if(rec == null) break;
System.out.println(rec.getStringProperty("text"));
session.rollback();
}
session.close();
Re: messages not moved to DLQ
Posted by Andreas Lanzl <an...@klipp.at>.
Justin, thx a lot. that did it!
________________________________
From: Justin Bertram <jb...@apache.org>
Sent: Wednesday, September 13, 2023 18:02
To: users@activemq.apache.org <us...@activemq.apache.org>
Subject: Re: messages not moved to DLQ
[You don't often get email from jbertram@apache.org. Learn why this is important at https://aka.ms/LearnAboutSenderIdentification ]
In order to register the delivery attempt you need to acknowledge the
message, e.g.:
while(true)
{
System.out.println("waiting for message");
ClientMessage rec = consumer.receive(5000);
if(rec == null) break;
rec.acknowledge();
System.out.println(rec.getStringProperty("text"));
session.rollback();
}
Justin
On Wed, Sep 13, 2023 at 4:01 AM Andreas Lanzl <an...@klipp.at>
wrote:
> Hi all.
>
> I'm trying to test the DLQ function in artemis V 2.30.0 but i can't get it
> working. My setup is like so:
> running artemis inside docker container with default configuration.
> According to the docs the
> max-delivery-attempts is by default 10. below is a little test programm
> written in java using the core client to connect to artemis. this test
> program creates a queue and sends one message and then consumes this
> message and rollback every consume. the issue is now that the message is
> received over and over again and not moved to the DLQ after 10 transmits.
> I also tried to set the max-delivery-attempts setting in broker.xml but
> this does not work either. (i have to mention that core client version is
> 2.19.1 due i use java 8)
>
> pls someone can point me in the right direction.. thx. -andreas
>
>
>
> ServerLocator locator =
> ActiveMQClient.createServerLocator("tcp://localhost:61616");
> ClientSessionFactory factory = locator.createSessionFactory();
> ClientSession session =
> factory.createSession("artemis","artemis1234",false,false,false,false,1);
>
> session.createAddress(new SimpleString("test"), RoutingType.MULTICAST,
> false);
>
> QueueConfiguration configuration = new QueueConfiguration("queue");
> configuration.setAddress("test");
>
> session.createQueue(configuration);
>
> ClientProducer producer = session.createProducer("test");
> ClientMessage message = session.createMessage(true);
> message.putStringProperty("text","test");
> producer.send(message);
> session.commit();
>
> session.start();
> ClientConsumer consumer = session.createConsumer("queue");
>
> while(true)
> {
> System.out.println("waiting for message");
> ClientMessage rec = consumer.receive(5000);
> if(rec == null) break;
> System.out.println(rec.getStringProperty("text"));
> session.rollback();
> }
>
> session.close();
>
>
Re: messages not moved to DLQ
Posted by Justin Bertram <jb...@apache.org>.
In order to register the delivery attempt you need to acknowledge the
message, e.g.:
while(true)
{
System.out.println("waiting for message");
ClientMessage rec = consumer.receive(5000);
if(rec == null) break;
rec.acknowledge();
System.out.println(rec.getStringProperty("text"));
session.rollback();
}
Justin
On Wed, Sep 13, 2023 at 4:01 AM Andreas Lanzl <an...@klipp.at>
wrote:
> Hi all.
>
> I'm trying to test the DLQ function in artemis V 2.30.0 but i can't get it
> working. My setup is like so:
> running artemis inside docker container with default configuration.
> According to the docs the
> max-delivery-attempts is by default 10. below is a little test programm
> written in java using the core client to connect to artemis. this test
> program creates a queue and sends one message and then consumes this
> message and rollback every consume. the issue is now that the message is
> received over and over again and not moved to the DLQ after 10 transmits.
> I also tried to set the max-delivery-attempts setting in broker.xml but
> this does not work either. (i have to mention that core client version is
> 2.19.1 due i use java 8)
>
> pls someone can point me in the right direction.. thx. -andreas
>
>
>
> ServerLocator locator =
> ActiveMQClient.createServerLocator("tcp://localhost:61616");
> ClientSessionFactory factory = locator.createSessionFactory();
> ClientSession session =
> factory.createSession("artemis","artemis1234",false,false,false,false,1);
>
> session.createAddress(new SimpleString("test"), RoutingType.MULTICAST,
> false);
>
> QueueConfiguration configuration = new QueueConfiguration("queue");
> configuration.setAddress("test");
>
> session.createQueue(configuration);
>
> ClientProducer producer = session.createProducer("test");
> ClientMessage message = session.createMessage(true);
> message.putStringProperty("text","test");
> producer.send(message);
> session.commit();
>
> session.start();
> ClientConsumer consumer = session.createConsumer("queue");
>
> while(true)
> {
> System.out.println("waiting for message");
> ClientMessage rec = consumer.receive(5000);
> if(rec == null) break;
> System.out.println(rec.getStringProperty("text"));
> session.rollback();
> }
>
> session.close();
>
>