Spring JMS消费者应用程序

Question

我已经用Apache ActiveMQ和一个简单的应用程序创建了一个JMS代理，该应用程序将消息纳入队列OK。

我想创建另一个简单的应用程序，使用MDP异步出列这些消息。以下是我到目前为止所拥有的一个例子：

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import org.apache.log4j.Logger;

public class MyMessageListener implements MessageListener {
private static final Logger LOG = Logger.getLogger(MyMessageListener.class);

  public void onMessage(Message message) {
   try {
    TextMessage msg = (TextMessage) message;
    LOG.info("Consumed message: " + msg.getText());
   } catch (JMSException e) {
    e.printStackTrace();
   }
  }
}

<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory"
p:brokerURL="tcp://localhost:61616 />
</bean>

<bean id="simpleMessageListener"
class="main.SimpleMessageListener">

<jms:listener-container
container-type="default"
connection-factory="connectionFactory"
acknowledge="auto">
<jms:listener destination="testqueue"
ref="simpleMessageListener" method="onMessage" />
</jms:listener-container>

现在我大概需要一个main方法，但是如果消息到达队列时监听器会异步调用onMessage方法，我不确定如何编写代码：

public class App {
  public static void main( String[] args ) {
  // what do I need here?
  //MyMessageListener msglistener ?
  }
}

谢谢你的帮助。

Answer 1

您需要启动Spring应用程序上下文，例如实例化ClasspAthXmlApplicationContext。参见http://docs.spring.io/spring/docs/current/spring-framework-reference/html/beans.html#beans-factory-instantiation