messages not moved to DLQ

[Andreas Lanzl]

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();