Wildfly 15 внешний пункт назначения Artemis ActiveMQ не найден - PullRequest
Новая
       89

Wildfly 15 внешний пункт назначения Artemis ActiveMQ не найден

0 голосов
/ 18 декабря 2018

У меня есть wildfly 15 с внешним ActiveMQ и я использую ресурсный адаптер.Но я не могу подключиться к очереди для записи.

Но я могу слушать в очереди.

вот моя конфигурация:

ironjacamar.xml: 

<admin-objects>
    <admin-object class-name="org.apache.activemq.command.ActiveMQQueue"
            jndi-name="java:jboss/activemq/queue/HELLOWORLDMDBQueue1234">
        <config-property name="PhysicalName">
                activemq/queue/HELLOWORLDMDBQueue
        </config-property>
    </admin-object>
</admin-objects>

ra.xml: 

<adminobject>
    <adminobject-interface>javax.jms.Queue</adminobject-interface>
    <adminobject-class>org.apache.activemq.command.ActiveMQQueue</adminobject-class>
    <config-property>
        <config-property-name>PhysicalName</config-property-name>
        <config-property-type>java.lang.String</config-property-type>
    </config-property>
</adminobject>

Bean.java: 

@Resource(lookup = "java:jboss/activemq/queue/HELLOWORLDMDBQueue1234")
private Queue queue;
@Inject
private JMSContext context;
someFunction(){
    context.createProducer().send(queue, "hier ist eine nachricht");
}

Мой компонент-слушатель: 

@ResourceAdapter("activemq.rar")
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "activemq/queue/HELLOWORLDMDBQueue") })
public class RemoteActiveMQConsumer implements MessageListener {
    @Override
    public void onMessage(Message msg) {
        if (msg instanceof TextMessage) {
            try {
                final String text = ((TextMessage) msg).getText();
                System.out.println(text);
            } catch (final JMSException e) {
                throw new RuntimeException(e);
            }
        } else {
            System.out.println(msg);
        }
    }
}

pom.xml для Beans содержит: 

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-client</artifactId>
    <version>5.9.1</version>
    <scope>provided</scope>
</dependency>

thisэто та же версия jar, что и в адаптере ресурсов.

Чтение из HELLOWORLDMDBQueue не является проблемой, но если я пытаюсь отправить, я получаю следующий вывод:

Ошибка:

Caused by: javax.jms.InvalidDestinationException: Foreign destination:queue://activemq/queue/HELLOWORLDMDBQueue
at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.checkDestination(ActiveMQMessageProducer.java:349)
at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:217)
at org.apache.activemq.artemis.jms.client.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:206)
at org.apache.activemq.artemis.ra.ActiveMQRAMessageProducer.send(ActiveMQRAMessageProducer.java:142)
at org.apache.activemq.artemis.jms.client.ActiveMQJMSProducer.send(ActiveMQJMSProducer.java:98)

Спасибо за помощь

1 Ответ

0 голосов
/ 18 декабря 2018

Подобно вашему другому вопросу на эту тему , похоже, что вы пытаетесь использовать объект admin из адаптера ресурсов JCA ActiveMQ 5.x для настройки объекта администратора очереди JMS, но затем выВы используете клиент ActiveMQ Artemis для работы с этой очередью.ActiveMQ 5.x и ActiveMQ Artemis - совершенно разные реализации клиент / сервер.Вы не можете смешивать их таким образом.

Вам не нужно настраивать что-либо, связанное с адаптером ресурсов ActiveMQ 5.x JCA.Просто определите свою очередь в подсистеме messaging Wildfly и создайте фабрики соединений, которые указывают на удаленного брокера.

...