Как создать DLQ на другом существующем DLQ, установить политику повторной доставки и т. Д.? - PullRequest
Новая
       18

Как создать DLQ на другом существующем DLQ, установить политику повторной доставки и т. Д.?

0 голосов
/ 02 июля 2018

В заявлении о проблеме требуется прочитать сообщения из существующего DLQ и определить политику повторной доставки в DLQ, чтобы создать DLQ для существующего.

открытый класс DLQonDLQ {

public static void main (final String [] args) выдает исключение {

      ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616"); 
      ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection("admin","admin");

      RedeliveryPolicy policy = connection.getRedeliveryPolicy();

      policy.setInitialRedeliveryDelay(500);
      policy.setBackOffMultiplier(2);
      policy.setUseExponentialBackOff(true);
      policy.setMaximumRedeliveries(2);

      Session session = connection.createSession(true, 0);

      Queue queue = session.createQueue("DLQ.exampleQueue");

      MessageConsumer messageConsumer = session.createConsumer(queue);

      connection.start();

      TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);
      System.out.println("1st delivery from " + queue.getQueueName() + ": " + messageReceived.getText());
      session.rollback();
...