Следующее мое код, чтобы запустить встроенный брокер с тремя очередями 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();
Код: Выделить всё
[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