Миграция от JBOSS Encedded JMS Broker в Remote ActiveMQ Artemis Broker ⇐ JAVA

[Anonymous]

мне нужно перенести все очереди и темы из существующего брокера JBoss, встроенного JBOSS, на удаленный брокер ActiveMQ Artemis (то есть за пределами сервера Jboss).
Я настроил как встроенный брокер, так и удаленное брокер в одном автономном файле. Удал одну очередь от встроенного брокера и добавил ее к удаленному брокеру и заостренным производителям и потребителям в удаленную очередь брокера. После полного переноса всех очередей/тем, я удалю встроенный брокер.

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

entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory"
connectors="in-vm"
transaction="xa"/>







< /code>
Добавлено ниже привязки сокета: < /p>

MDB для Testqueue , как ниже:

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

@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName="destination",             propertyValue="TestQueue"),
@ActivationConfigProperty(propertyName="destinationType",         propertyValue="jakarta.jms.Queue"),
@ActivationConfigProperty(propertyName="connectionFactoryLookup", propertyValue="java:/jms/DemoRemoteCF"),
@ActivationConfigProperty(propertyName="acknowledgeMode",         propertyValue="Auto-acknowledge"),
@ActivationConfigProperty(propertyName="useJNDI",                 propertyValue="false"),
@ActivationConfigProperty(propertyName="maxSession",              propertyValue="1")
})
public class DemoConnectorMDB implements MessageListener {
public void onMessage(Message m) { /* ... */ }
}
< /code>
При запуске сервера Jboss он непрерывно регистрирует < /p>
10:13:24,525 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:26,525 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:26,528 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:28,529 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:28,535 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:30,536 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:30,538 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:32,539 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:32,541 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:34,542 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:34,550 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:36,551 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:36,554 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:38,554 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:38,556 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:40,557 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:40,563 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:42,563 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.
10:13:42,565 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151000: awaiting topic/queue creation TestQueue
10:13:44,566 INFO [org.apache.activemq.artemis.ra.ActiveMQRALogger] (default-threads - 4) AMQ151004: Instantiating jakarta.jms.Queue "TestQueue" directly since UseJNDI=false.

Я мог бы создать сообщения в Testqueue , но MDB не потреблял эти сообщения из TestQueue . Любые решения по этому вопросу были бы действительно полезны.
Любые предложения по этой миграции также очень полезны.>

Подробнее здесь: https://stackoverflow.com/questions/797 ... mis-broker