0

我正在尝试从位于远程服务器上的远程 jms 队列中读取消息，也在 WildFly 8.2.0 上。远程服务器上定义的远程队列名称是“java:jboss/exported/jms/queue/grinderRemote”。

我在读取服务器上定义了一个同名队列，但我不确定它是否正确。

对于阅读消息，我创建了一个带有 MDB 类的动态 Web 项目。代码如下

package it.vr.pms;

import java.util.logging.Logger;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;


@MessageDriven(name = "ReadJMS1", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "/exported/jms/queue/grinderRemote"),
    @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"), 
    @ActivationConfigProperty(propertyName = "user", propertyValue = "jmsuser"), 
    @ActivationConfigProperty(propertyName = "password", propertyValue = "********"),
    //@ActivationConfigProperty(propertyName = "connectorClassName", propertyValue = "org.hornetq.core.remoting.impl.netty.NettyConnectorFactory"),
    //@ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "false"),
    @ActivationConfigProperty(propertyName = "connectionParameters", propertyValue = "host=http-remoting://192.168.5.124;port=8080")})
public class ReadJMS1 implements MessageListener {

    private final static Logger LOGGER = Logger.getLogger(ReadJMS1.class.toString());


    public void onMessage(Message rcvMessage) {
        TextMessage msg = null;
        try {
            if (rcvMessage instanceof TextMessage) {
                msg = (TextMessage) rcvMessage;
                System.out.println("Received Message from queue: " + msg.getText());
            } else {
                System.out.println("Message of wrong type: " + rcvMessage.getClass().getName());
            }
        } catch (JMSException e) {
            throw new RuntimeException(e);
        }
    }
}

“阅读器”服务器日志如下：

10:26:10,273 INFO  [org.hornetq.ra] (default-threads - 1) HQ151000: awaiting topic/queue creation /exported/jms/queue/grinderRemote
10:26:10,336 INFO  [org.wildfly.extension.undertow] (MSC service thread 1-4) JBAS017534: Registered web context: /TestJMSReceive
10:26:10,492 INFO  [org.jboss.as.server] (ServerService Thread Pool -- 31) JBAS018559: Deployed "TestJMSReceiveEAR.ear" (runtime-name : "TestJMSReceiveEAR.ear")
10:26:10,836 INFO  [org.jboss.as] (Controller Boot Thread) JBAS015961: Http management interface listening on http://0.0.0.0:9990/management
10:26:10,836 INFO  [org.jboss.as] (Controller Boot Thread) JBAS015951: Admin console listening on http://0.0.0.0:9990
10:26:10,836 INFO  [org.jboss.as] (Controller Boot Thread) JBAS015874: WildFly 8.2.0.Final "Tweek" started in 9312ms - Started 326 of 386 services (112 services are lazy, passive or on-demand)
10:26:12,304 INFO  [org.hornetq.ra] (default-threads - 1) HQ151001: Attempting to reconnect org.hornetq.ra.inflow.HornetQActivationSpec(ra=org.hornetq.ra.HornetQResourceAdapter@48b7ee22 destination=/exported/jms/queue/grinderRemote destinationType=javax.jms.Queue ack=Auto-acknowledge durable=false clientID=null user=jmsuser password=**** maxSession=15)

我不明白我错在哪里。我也尝试使用注释过的@ActivationConfigProperty，但结果是一样的......

任何帮助表示赞赏。

谢谢

编辑

我做了 apocalypz 建议的配置，但现在错误如下：

15:25:47,116 INFO  [org.jboss.as.ejb3] (MSC service thread 1-1) JBAS014142: Started message driven bean 'ReadJMS1' with 'hornetq-ra.rar' resource adapter
15:25:47,163 WARN  [org.hornetq.ra] (default-threads - 1) HQ152005: Failure in HornetQ activation org.hornetq.ra.inflow.HornetQActivationSpec(ra=org.hornetq.ra.HornetQResourceAdapter@71996bda destination=queue/LocalServer1Q destinationType=javax.jms.Queue ack=Auto-acknowledge durable=false clientID=null user=null maxSession=15): javax.naming.NameNotFoundException: jms/RemoteConnectionFactory -- service jboss.naming.context.java.jms.RemoteConnectionFactory

似乎它试图使用资源适配器 hornetq-ra 而不是 RemoteConnectionFactory。还是在另一台服务器上找不到 RemoteConnectionFactory？

4

2 回答 2

0

您需要使用 MDB 在服务器上配置 RemoteConnectionFactory（在您当前使用的 Wildfly 配置中，例如standalone-full.xml），然后通过“connectionFactoryLookup”属性进行设置。目的地不需要在 jboss/exported ns 中。

@MessageDriven(name = "RemoteQueueConsumer", 
activationConfig = { 
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:jboss/jms/queue/RemoteQueue"),
    @ActivationConfigProperty(propertyName = "connectionFactoryLookup", propertyValue = "java:jboss/jms/RemoteConnectionFactory"),              
    @ActivationConfigProperty(propertyName = "user", propertyValue = "user1"),
    @ActivationConfigProperty(propertyName = "password", propertyValue = "pwd.123"),  
    @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
    @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "messageType=testMessage") 
})

对于 RemoteConnectionFactory 配置，您必须将 ConnectionFactory 指向连接器，它引用了出站套接字绑定。

于 2015-02-05T12:48:54.953 回答
0

如果有人需要使用 Wildfly (Jboss) 的其他解决方案，这篇文章再举一个例子

@ResoucerAdapter

于 2017-04-19T17:49:16.820 回答