使用Active MQ的示例JMS示例
问题描述:
我想使用Active MQ学习JMS应用程序。
所以下载了apache-activemq-5.5.1并启动了服务器
并找到了示例代码但是没有工作。为什么会发生异常?
注:我添加的ActiveMQ库,我的项目和库包含org.slf4j模块使用Active MQ的示例JMS示例
import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.MessageListener;
//JMS Producer
public class JMSProducer {
public void produce() {
String url = "tcp://localhost:61616";
ConnectionFactory factory = new ActiveMQConnectionFactory(url);
try {
Connection connection = factory.createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic("TestTopic");
MessageProducer producer = session.createProducer(topic);
TextMessage msg = session.createTextMessage();
msg.setText("Hello JMS World");
producer.send(msg);
}
catch(JMSException exp) {
}
}
}
//JMS Consumer
public class JMSConsumer {
public void consume() {
String url = "tcp://localhost:61616";
ConnectionFactory factory = new ActiveMQConnectionFactory(url);
try {
Connection connection = factory.createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic("TestTopic");
MessageConsumer consumer = session.createConsumer(topic);
JMSMessageListener listener = new JMSMessageListener();
consumer.setMessageListener(listener);
connection.start();
}
catch(JMSException exp) {
}
}
}
//JMS Message Listener
public class JMSMessageListener implements MessageListener {
@Override
public void onMessage(javax.jms.Message msg) {
System.out.println(msg.toString());
}
}
答
报告该错误时org.slf4j.impl.StaticLoggerBinder 类不能被加载到内存中。当在类路径上找不到合适的SLF4J绑定时,会发生这种情况。将 中的一个(并且只有一个)slf4j-nop.jar,slf4j-simple.jar, slf4j-log4j12.jar,slf4j-jdk14.jar或者类 上的logback-classic.jar路径应该解决问题。
自1.6.0自SLF4J版本1.6起,在没有绑定的情况下,SLF4J将默认为无操作(NOP)记录器实现。
您可以从项目下载页面下载SLF4J绑定。
+1 - 这帮助了我。在尝试使用JMS的不同方式并且使用比ActiveMQ 5.9.1要求的SLF4J更早版本的glassfish的情况下,有一个pom。注释掉pom中的glassfish依赖关系导致一切正常。 – rishimaharaj 2014-04-27 04:50:01