当我尝试下面的代码时,Producer and & Destination出现以下错误。我是否使用了正确的连接工厂?
-
方法 createQueue(String) 未定义类型会话
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);
我找到了解决方案!您使用了错误的导入。使用 org.hibernate.session,错误将消失。