错误：未为 Session 类型定义方法 createQueue(String)

Question

当我尝试下面的代码时，生产者和目的地出现以下错误。我是否使用了正确的连接工厂？

• 方法 createQueue(String) 未定义 Session 类型

  import org.apache.activemq.ActiveMQConnection;
  import org.apache.activemq.ActiveMQConnectionFactory;
  import javax.jms.Connection;
  import javax.jms.DeliveryMode;
  import javax.jms.Destination;
  import javax.jms.ExceptionListener;
  import javax.jms.JMSException;
  import javax.jms.Message;
  import javax.jms.MessageConsumer;
  import javax.jms.MessageProducer;
  import javax.jms.QueueConnection;
  import javax.jms.QueueConnectionFactory;
  import javax.jms.Session;
  import javax.jms.TextMessage;  
  
      public class MQProdCons {
      public static void main(String[] args) {
          try {            
          QueueConnectionFactory connectionFactory = new ActiveMQConnectionFactory(getSendHost());              
          QueueConnection connection = connectionFactory.createQueueConnection();  
          connection.start();
          // Create a session
          Session session = connection.createQueueSession(false,
                  Session.AUTO_ACKNOWLEDGE);
          // Connect to queues
          Destination requestQ = session.createQueue (getReportQueue());
  
          MessageProducer producer = session.createProducer(requestQ);
          Destination responseQ = session.createQueue(getReceiveQueue());
  
          MessageConsumer consumer = session.createConsumer(responseQ);
          producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  

Answer 1

我找到了解决方案！ 您使用了错误的导入。使用 org.hibernate.Session，错误就会消失。