2

我正在尝试捕获由于代理关闭而无法建立的 ActiveMQ 连接的异常。

使用以下代码：

String url = ActiveMQConnection.DEFAULT_BROKER_URL;                
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start();

如果代理关闭，则连接到代理的尝试进入无限循环。如果我将网址更改为

String url = "failover:(tcp://127.0.0.1:61616/)?startupMaxReconnectAttempts=2";

它进行了 2 次尝试，然后抛出异常。（这就是我想要的。）

现在，如果我使用以下 Spring Bean 初始化连接对象：

<bean id="jmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL">
        <!--<value>tcp://0.0.0.0:61616</value>-->
        <value>failover:(tcp://127.0.0.1:61616/)?startupMaxReconnectAttempts=2</value>
    </property>
</bean>

我收到一条错误消息，提示无法在 2 次尝试中连接，但随后，它仍会在每 5 秒后再次尝试连接，再次给出相同的错误消息并继续无限循环。

ERROR transport.failover.FailoverTransport - Failed to connect to [tcp://127.0.0.1:61616/] after: 2 attempt(s)
WARN jms.listener.DefaultMessageListenerContainer - Could not refresh JMS Connection for destination 'destinationQueue' - retrying in 5000 ms. Cause: Connection refused
ERROR transport.failover.FailoverTransport - Failed to connect to [tcp://127.0.0.1:61616/] after: 2 attempt(s)
WARN jms.listener.DefaultMessageListenerContainer - Could not refresh JMS Connection for destination 'destinationQueue' - retrying in 5000 ms. Cause: Connection refused
ERROR transport.failover.FailoverTransport - Failed to connect to [tcp://127.0.0.1:61616/] after: 2 attempt(s)
WARN jms.listener.DefaultMessageListenerContainer - Could not refresh JMS Connection for destination 'destinationQueue' - retrying in 5000 ms. Cause: Connection refused
ERROR transport.failover.FailoverTransport - Failed to connect to [tcp://127.0.0.1:61616/] after: 2 attempt(s)
WARN jms.listener.DefaultMessageListenerContainer - Could not refresh JMS Connection for destination 'destinationQueue' - retrying in 5000 ms. Cause: Connection refused
these messages repeat!!

我想知道如何停止这种无限轮询并在失败的情况下捕获异常（可能正在使用 PostInit）。

4

1 回答 1

0

您可以在侦听器类中实现 ExceptionListener 并覆盖 onException 消息。在那里你可以处理你的通知逻辑。虽然它尝试自动重新连接。

public class QueueListener implements MessageListener,ExceptionListener{

public void onMessage(Message message) {

}

public void onException(JMSException jsme) {

 // Send my notifcation here.

}


}
于 2012-11-28T06:09:06.793 回答