在Thorntail中使用ActiveMQ配置JMS

thorntail:
  messaging-activemq:
    server-url: tcp://localhost:61616
    user: <username>
    password: <password>

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.16.3</version>
</dependency>

import javax.annotation.Resource;
import javax.jms.ConnectionFactory;
import javax.jms.JMSContext;
import javax.jms.Queue;

// JMS消息生产者
public class JmsProducer {

    @Resource(lookup = "java:/ConnectionFactory")
    private ConnectionFactory connectionFactory;

    @Resource(lookup = "java:/jms/queue/ExampleQueue")
    private Queue queue;

    public void sendMessage(String message) {
        try (JMSContext context = connectionFactory.createContext()) {
            context.createProducer().send(queue, message);
        }
    }
}

// JMS消息消费者
public class JmsConsumer {

    @Resource(lookup = "java:/ConnectionFactory")
    private ConnectionFactory connectionFactory;

    @Resource(lookup = "java:/jms/queue/ExampleQueue")
    private Queue queue;

    public void receiveMessage() {
        try (JMSContext context = connectionFactory.createContext()) {
            String message = context.createConsumer(queue).receiveBody(String.class);
            System.out.println("Received message: " + message);
        }
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<jms-queue xmlns="urn:jboss:jms-queue:1.0">
    <queue name="ExampleQueue">
        <entry name="java:/jms/queue/ExampleQueue"/>
    </queue>
</jms-queue>