1

我正在使用带有 Spring 的 Apache Active MQ ......我面临的问题是我正在一台机器上创建生产者，比如说 Machine1，我正在第二台机器上创建一个消费者，比如说 Machine2 ......我正在创建生产者Machine1 通过调用一个简单的 servlet 调用......然后在 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);
4

1 回答 1

2

我不会为这种情况设置消息监听器，而只是使用 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){

}
于 2012-07-31T08:09:51.520 回答