JMS Connection 在向未经授权的路由发送消息时不抛出 JMSSecurityException

Question

我正在使用 Apache Camel 和 Spring 从我的 Java 服务发送消息。我需要 handle/trigger 某些事件以防在交换时发生任何错误。我正在使用下面的代码来实现我的 objective.

try
    {
        producerTemplate.sendBody(endPoint, bytes);
    }
    catch (final RuntimeCamelException exception)
    {
        LOGGER.error("Exception occured in sendBody", exception.getMessage(), exception);
        handleError(); // handle error here.
    }

为了测试我将 endPoint 的值设置为错误的路由名称 broadcast.SIMULATOR.ROUTE1。当我在代码上方运行时，我可以在控制台中看到以下错误，但它永远不会出现在 catch 块中。

[33m16:15:51,714 WARN  [org.springframework.jms.connection.CachingConnectionFactory] (QpidJMS Connection Executor: ID:7dacac8c-93ce-48c0-92fe-8dc0e8:1) Encountered a JMSException - resetting the underlying JMS Connection: javax.jms.JMSSecurityException: Admin@QPID9019 cannot publish to broadcast with routing-key broadcast.SIMULATOR.ROUTE1 (/builddir/build/BUILD/qpid-cpp-1.36.0/src/qpid/broker/amqp/Authorise.cpp:126) [condition = amqp:unauthorized-access]
at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:143) [qpid-jms-client-0.23.0.jar:]
at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:117) [qpid-jms-client-0.23.0.jar:]

我正在向路由发送多条消息。对于第一条消息，JMSSecurityException 记录在控制台中并继续执行。从第二条消息开始，执行进入捕获 IllegalStateException（会话已关闭）.

如何在仅包含第一条消息的 catch 块中执行（对于 JMSSecurityException）？

Answer 1

这取决于您使用的 JMS 客户端。因为他们中的一些人以异步方式发送消息。他们可能有一个配置选项，您可以使用它来关闭它。

例如 Apache ActiveMQ 有这个带有 asyncSend 选项 http://activemq.apache.org/async-sends.html 然后您可以将其关闭。

JMS Connection 在向未经授权的路由发送消息时不抛出 JMSSecurityException

JMS Connection not throwing JMSSecurityException on sending message to unauthorized route

java

apache-camel

spring-jms

qpid

jms-topic