使用Active MQ的示例JMS示例

我想使用Active MQ学习JMS应用程序。
所以下载了apache-activemq-5.5.1并启动了服务器
并找到了示例代码但是没有工作。为什么会发生异常？
注：我添加的ActiveMQ库，我的项目和库包含org.slf4j模块使用Active MQ的示例JMS示例

exception

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()); 
      } 
     }

来源

2012-02-15 onurozcelik

报告该错误时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绑定。

http://www.slf4j.org/codes.html#StaticLoggerBinder

来源

2012-02-15 10:10:20 Lukasz

+1 - 这帮助了我。在尝试使用JMS的不同方式并且使用比ActiveMQ 5.9.1要求的SLF4J更早版本的glassfish的情况下，有一个pom。注释掉pom中的glassfish依赖关系导致一切正常。 – rishimaharaj 2014-04-27 04:50:01

使用Active MQ的示例JMS示例

回答

相关问题