Привязка адреса к очереди не работает для встроенного ActiveMQ ArtemisJAVA

Программисты JAVA общаются здесь
Ответить Пред. темаСлед. тема
Anonymous
 Привязка адреса к очереди не работает для встроенного ActiveMQ Artemis

Сообщение Anonymous »

Я пытаюсь проверить свой код продюсера JMS в моем приложении Spring Boot с встроенным ActiveMQ Artemis.
Следующее мое код, чтобы запустить встроенный брокер с тремя очередями test.queue.0 < /code>, test.queue.1 и test.queue.2

Код: Выделить всё

Configuration embeddedActiveMqServerConfig = new ConfigurationImpl();
embeddedActiveMqServerConfig
//.addAcceptorConfiguration("in-vm", "vm://0")
.addAcceptorConfiguration("tcp", "tcp://127.0.0.1:61616")
.setResolveProtocols(false)
.addQueueConfiguration((new QueueConfiguration("test.queue.0")).setAddress("test.queue.0").setRoutingType(RoutingType.ANYCAST).setEnabled(true))
.addQueueConfiguration((new QueueConfiguration("test.queue.1")).setAddress("test.queue.1").setRoutingType(RoutingType.ANYCAST).setEnabled(true))
.addQueueConfiguration((new QueueConfiguration("test.queue.2")).setAddress("test.queue.2").setRoutingType(RoutingType.ANYCAST).setEnabled(true))
.setSecurityEnabled(false);
embeddedActiveMqServer = new EmbeddedActiveMQExtension(embeddedActiveMqServerConfig);
embeddedActiveMqServer.start();
Код производителя работает нормально, и я могу создавать новые сообщения в test.queue.0 и получать взамен jmsId, но я получаю следующий оператор отладки в консоль для созданного сообщения

Код: Выделить всё

[Thread-9 (ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@4a901445)] DEBUG o.a.a.a.c.p.impl.PostOfficeImpl - Message CoreMessage[messageID=60129543556,durable=true,userID=9e9c9f71-da53-11ef-83f3-0205857feb80,priority=4, timestamp=Fri Jan 24 14:03:34 CET 2025,expiration=0, durable=true, address=test.queue.0,size=415,properties=TypedProperties[__AMQ_CID=9cba23cc-da53-11ef-83f3-0205857feb80,uber_$dash$_trace_$dash$_id=efcf8ad9a21d1b0b:fabdfb38a47041e6:efcf8ad9a21d1b0b:0,_AMQ_ROUTING_TYPE=1]]@1341335240 is not going anywhere as it didn't have a binding on address:test.queue.0
Согласно этому сообщению, привязка адреса отсутствует, как и в моем произведенном сообщении, отправленном в адрес адреса. , поскольку между ними нет связи, но у меня есть ассоциация в моей конфигурации. /п>

Подробнее здесь: https://stackoverflow.com/questions/793 ... mq-artemis
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «JAVA»