Чтобы отправить сообщение JMS в удаленную очередь ActiveMQ Artemis, встроенную в JBoss EAP, вы можете использовать значение по умолчанию standalone-full.xml. Вам не нужно настраивать удаленный соединитель, фабрику пулов соединений, или удаленное связывание. Вам просто нужно искать jms/RemoteConnectionFactory с вашего клиента, используя JBD-контекст JBoss EAP. Понятно, что когда ActiveMQ Artemis встроен в удаленные клиенты JBoss EAP, используется контекст JNDI JBoss EAP, а не JNDI-контекст ActiveMQ Artemis, поскольку сам EAP отвечает за все операции JNDI.
Ваш клиент использует Artemis ActiveMQ Контекст JNDI:
initialProperties.put(InitialContext.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
initialProperties.put(InitialContext.PROVIDER_URL, "tcp://127.0.0.1:61616");
Это неверно. Вы должны использовать это вместо:
initialProperties.put(InitialContext.INITIAL_CONTEXT_FACTORY, "org.wildfly.naming.client.WildFlyInitialContextFactory");
initialProperties.put(InitialContext.PROVIDER_URL, "http-remoting://127.0.0.1:8080");
Примечание: Вы также можете использовать org.jboss.naming.remote.client.InitialContextFactory здесь, потому что этот класс также поставляется с JBoss EAP 7.2. Однако этот класс действительно включен для обратной совместимости с устаревшими клиентами.
Затем ваш клиент пытается найти pooled-connection-factory, настроенный вами в standalone-full.xml:
factory = (QueueConnectionFactory) context.lookup("java:/jms/remoteIM");
Это также неверен. pooled-connection-factory может только использоваться клиентами, работающими в той же JVM, что и JBoss EAP (например, MDB, которому необходимо отправить сообщение). Вы не можете просто найти его с удаленного клиента и ожидать получения пула. Это не так, как это работает. Вы должны сделать это вместо этого:
factory = (QueueConnectionFactory) context.lookup("jms/RemoteConnectionFactory");
Это будет использовать значение по умолчанию connection-factory в standalone-full.xml с именем RemoteConnectionFactory.
Затем вы ищите очередь, которая не ' даже определяется в подсистеме обмена сообщениями (т. е. java:global/remoteContext/ImportantMessages). Вы, очевидно, настроили его в external-context по какой-то причине. Это неправильно для EAP. Вы должны определить это в вашем standalone-full.xml:
<jms-queue name="ImportantMessages" entries="java:jboss/exported/ImportantMessages"/>
И затем использовать это в своем клиенте:
destination = (Queue) context.lookup("ImportantMessages");
В конечном счете, именно так должна выглядеть ваша подсистема обмена сообщениями в standalone-full.xml например:
<subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0">
<server name="default">
<journal pool-files="10"/>
<security-setting name="#">
<role name="guest" send="true" consume="true" create-non-durable-queue="true" delete-non-durable-queue="true"/>
</security-setting>
<address-setting name="#" dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue" max-size-bytes="10485760" page-size-bytes="2097152" message-counter-history-day-limit="10"/>
<http-connector name="http-connector" socket-binding="http" endpoint="http-acceptor"/>
<http-connector name="http-connector-throughput" socket-binding="http" endpoint="http-acceptor-throughput">
<param name="batch-delay" value="50"/>
</http-connector>
<in-vm-connector name="in-vm" server-id="0">
<param name="buffer-pooling" value="false"/>
</in-vm-connector>
<http-acceptor name="http-acceptor" http-listener="default"/>
<http-acceptor name="http-acceptor-throughput" http-listener="default">
<param name="batch-delay" value="50"/>
<param name="direct-deliver" value="false"/>
</http-acceptor>
<in-vm-acceptor name="in-vm" server-id="0">
<param name="buffer-pooling" value="false"/>
</in-vm-acceptor>
<jms-queue name="ImportantMessages" entries="java:jboss/exported/ImportantMessages"/>
<jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
<jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
<connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="in-vm"/>
<connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>
<pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="xa"/>
</server>
</subsystem>
Вам не нужно настраивать external-context, который вы настроили.
Наконец, вот как в конечном итоге должен выглядеть ваш клиент:
public void sendObjectMessage() {
Properties initialProperties = new Properties();
initialProperties.put(InitialContext.INITIAL_CONTEXT_FACTORY, "org.wildfly.naming.client.WildFlyInitialContextFactory");
initialProperties.put(InitialContext.PROVIDER_URL, "http-remoting://127.0.0.1:8080");
try {
context = new InitialContext(initialProperties);
factory = (QueueConnectionFactory) context.lookup("jms/RemoteConnectionFactory");
destination = (Queue) context.lookup("ImportantMessages");
connection = factory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
producer = session.createProducer(destination);
EventMessage eventMessage = new EventMessage("1", "Message from FirstClient");
ObjectMessage objectMessage = session.createObjectMessage();
objectMessage.setObject(eventMessage);
connection.start();
producer.send(objectMessage);
System.out.println(this.getClass().getName() + "has sent a message : " + eventMessage);
} catch (NamingException e) {
e.printStackTrace();
} catch (JMSException e) {
e.printStackTrace();
} finally {
if (context != null) {
try {
context.close();
} catch (NamingException ex) {
ex.printStackTrace();
}
}
if (connection != null) {
try {
connection.close();
} catch (JMSException ex) {
ex.printStackTrace();
}
}
}
}
В JBoss EAP есть куча «быстрых» приложений, демонстрирующих использование его функций. Вот краткий старт JMS "Hello World" , который может оказаться полезным для справки.
Если вы создаете свое клиентское приложение с Maven, то эту зависимость вы должны использовать:
<dependency>
<groupId>org.jboss.eap</groupId>
<artifactId>wildfly-jms-client-bom</artifactId>
<type>pom</type>
</dependency>
Кроме того, имейте в виду, что ActiveMQ Artemis, встроенный в JBoss EAP 7.2, защищен по умолчанию, поэтому вам необходимо либо отключить защиту в подсистеме обмена сообщениями (например, с помощью <security enabled="false"/>), либо добавить пользователя в ApplicationRealm (например, с помощью сценария bin/add-user.sh) и передайте правильные учетные данные, когда вы создаете соединение .