Apache ActiveMQ 回退机制

Question

我正在使用带有 Spring 的 Apache Active MQ ......我面临的问题是我在一台机器上创建生产者，比如说 Machine1，我正在第二台机器上创建一个消费者，比如说 Machine2...... 我通过调用简单的 servlet 调用在 Machine1 上创建生产者......然后在 Machine2 上创建消费者...... 我面临的问题是，无论如何，如果我的生产者无法在指定的时间内发送任何数据包，那么我想从 Machine2 中删除我的消费者和队列...... 无论如何，如果我在指定的时间内没有从生产者那里收到任何数据包，我可以设置我的消费者和队列来自动删除并执行一些业务逻辑....

connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD,ConnectorURL);
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(transacted, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue(queueID+"");
connection = connectionFactory.createConnection();
connection.start();
consumer = session.createConsumer(destination);

基本上这段代码为我的应用程序创建消费者......然后我将此消费者分配给我的应用程序监听器，监听生产者是否向消费者发送任何消息......

ScenarioExecutionQueueListenerImpl executionQueueListener = new ScenarioExecutionQueueListenerImpl(scenario,result, host);
beanFactory.autowireBean(executionQueueListener);
connection.setExceptionListener(executionQueueListener);
Message message = consumer.receive();
consumer.setMessageListener(executionQueueListener);
executionQueueListener.setConsumer(consumer);
executionQueueListener.onMessage(message);

Answer 1

我不会为这种情况设置消息监听器，而只是使用 consumer.receive() 方法。 MessageListener 更适合时间独立/异步消耗。

public void run(){
  Message m = consumer.receive(timeout_value_in_millisec);
  if( m != null ){
     // got a message, handle it.
     processMessage(msg);
  }else{
     // no message received in specified time, 
  }
  // close session, connection etc.
}

public void processMessage(Message msg){

}