<dependency>
        <groupId>cn.hinglo.activemq</groupId>
        <artifactId>activemqplugin</artifactId>
        <version>1.0.0</version>
    </dependency>

    ActiveMqPlugin activeMqPlugin = new ActiveMqPlugin("tcp://127.0.0.1:61616");
    plugins.add(activeMqPlugin);

ActiveMQTextMessage message = new ActiveMQTextMessage();
message.setText("Hello world");
// Отправка сообщения в очередь, параметры: имя очереди, объект сообщения, для отправки сообщения в тему используйте: sendTopicsMsg
SendMsgKit.sendQueueMsg("queue-test", message);
```способ 2: Использование сессии для создания и отправки сообщений через native JMS интерфейс,
```java
// Используем SessionKit для получения сессии
Session session = SessionKit.getJmsSession();
TextMessage message = session.createTextMessage("Сообщение, созданное с помощью сессии");
// Отправка сообщения в очередь, параметры: имя очереди, объект сообщения, сессия, для отправки сообщения в тему используйте: sendTopicsMsg
SendMsgKit.sendQueueMsg("queue-test", message, session);

@MsgListener("queue-test")
public class TestMessageListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        TextMessage textMessage = (TextMessage) message;
        try {
            System.out.println(textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

// Основной код
ActiveMQDestination queues = (ActiveMQDestination) message.getJMSDestination();
if (queues.getPhysicalName().equalsIgnoreCase("queue1")) {
    // Бизнес-логика ...
} else if (queues.getPhysicalName().equalsIgnoreCase("queue2")) {
    // Бизнес-логика ...
} ...
```## Завершение
**Это мой первый опыт работы с ActiveMQ, используемые элементы довольно просты, функционал плагинов ограничен, поэтому реализуется только базовая отправка сообщений. Если в коде есть ошибки, прошу вас указать на них и дать советы. Также вы можете внести изменения в код в соответствии со своими требованиями.**