禁用ActivemMQ邮件的DLQ和重新传递

<broker>
  ...
  <destinationPolicy>
    <policyMap>
      <policyEntries>
        <policyEntry queue=">" deadLetterStrategy="com.example.MyDeadLetterStrategy" />
      </policyEntries>
    </policyMap>
  </destinationPolicy>
  ...
</broker>

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

public class MessageRedeliveryExample {
    public static void main(String[] args) {
        String brokerURL = "tcp://localhost:61616";
        String queueName = "your_queue_name";

        try {
            // 创建连接工厂
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerURL);
            // 创建连接
            Connection connection = connectionFactory.createConnection();
            // 启动连接
            connection.start();
            // 创建会话
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // 创建目标队列
            Destination destination = session.createQueue(queueName);
            // 创建消息消费者
            MessageConsumer consumer = session.createConsumer(destination);

            // 接收消息并处理
            Message message = consumer.receive();
            // 处理消息...

            // 如果处理失败，可以重新传递消息到其他队列
            // 创建目标队列
            Destination newDestination = session.createQueue("other_queue_name");
            // 创建消息生产者
            MessageProducer producer = session.createProducer(newDestination);
            // 发送消息
            producer.send(message);

            // 关闭资源
            producer.close();
            consumer.close();
            session.close();
            connection.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}