Context context = new InitialContext(); ConnectionFactory factory = (ConnectionFactory) context.lookup("jms/ConnectionFactory"); Connection connection = factory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Queue queue = (Queue) context.lookup("jms/Queue"); MessageProducer producer = session.createProducer(queue); TextMessage message = session.createTextMessage("Hello JMS!"); message.setJMSDeliveryMode(DeliveryMode.PERSISTENT); producer.send(message); Context context = new InitialContext(); ConnectionFactory factory = (ConnectionFactory) context.lookup("jms/ConnectionFactory"); Connection connection = factory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Queue queue = (Queue) context.lookup("jms/Queue"); MessageConsumer consumer = session.createConsumer(queue); connection.start(); TextMessage message = (TextMessage) consumer.receive(); System.out.println("Received message: " + message.getText()); Context context = new InitialContext(); ConnectionFactory factory = (ConnectionFactory) context.lookup("jms/ConnectionFactory"); Connection connection = factory.createConnection(); Session session = connection.createSession(true, Session.SESSION_TRANSACTED); Queue queue = (Queue) context.lookup("jms/Queue"); MessageProducer producer = session.createProducer(queue); TextMessage message1 = session.createTextMessage("Message 1"); TextMessage message2 = session.createTextMessage("Message 2"); producer.send(message1); producer.send(message2); session.commit();


上一篇:
下一篇:
切换中文