来自远程ActiveMQ Artemis的Wildfly JMS使用者

Question

我试图在Wildfly（版本24）和远程ActiveMQ Artemis代理中实现简单的JMS生产者和消费者。

独立的。xml

<subsystem xmlns="urn:jboss:domain:messaging-activemq:13.0">
    <remote-connector name="remote-artemis" socket-binding="remote-artemis"/>
    <pooled-connection-factory
        name="remote-artemis"
        entries="java:/jms/remoteCF" 
        connectors="remote-artemis" 
        client-id="producer-pooled-connection-factory"
        user="${artemismq.user}"
        password="${artemismq.password}"
        enable-amq1-prefix="true"
    />
    <external-jms-queue name="testQueue" entries="java:/queue/testQueue"/>
</subsystem>

<socket-binding-group name="standard-sockets" default-interface="public" port-offset="${jboss.socket.binding.port-offset:0}">
    <socket-binding name="ajp" port="${jboss.ajp.port:8009}"/>
    <socket-binding name="http" port="${jboss.http.port:8080}"/>
    <socket-binding name="https" port="${jboss.https.port:8443}"/>
    <socket-binding name="management-http" interface="management" port="${jboss.management.http.port:9990}"/>
    <socket-binding name="management-https" interface="management" port="${jboss.management.https.port:9993}"/>
    <socket-binding name="txn-recovery-environment" port="4712"/>
    <socket-binding name="txn-status-manager" port="4713"/>
    <outbound-socket-binding name="mail-smtp">
        <remote-destination host="${jboss.mail.server.host:localhost}" port="${jboss.mail.server.port:25}"/>
    </outbound-socket-binding>
    <outbound-socket-binding name="remote-artemis">
        <remote-destination host="${artemismq.host}" port="${artemismq.port}"/>
    </outbound-socket-binding>
</socket-binding-group>

生产者和消费者

    @Inject
    @JMSConnectionFactory("java:/jms/remoteCF")
    private JMSContext context;

    @Resource(lookup = "java:/queue/testQueue")
    private Queue queue;

    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        resp.setContentType("text/html");
        PrintWriter out = resp.getWriter();
        try {
            out.write("<p>Sending messages to <em>" + queue + "</em></p>");
            out.write("<p>Using context <em>" + context + "</em></p>");
            out.write("<h2>The following messages will be sent to the destination:</h2>");
            for (int i = 0; i < MSG_COUNT; i++) {
                String text = "This is message " + (i + 1);
                context.createProducer().send(queue, text);
                out.write("Message (" + i + "): " + text + "</br>");

                JMSConsumer consumer = context.createConsumer(queue);
                TextMessage message = (TextMessage) consumer.receive();
                out.write("Message received (" + i + "): " + message.getText() + "</br>");
            }
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            if (out != null) {
                out.close();
            }
        }
    }

Misc：只有制片人才能工作。

结果：代理收到第一条消息，但没有执行消费，也没有发生任何事情（没有日志）。

Answer 1

关于池连接工厂，文档中说：

当在JNDI中查找或注入时，它应该仅用于发送（即产生）消息。

您应该创建一个“正常”连接工厂，供消费者使用。