1. Provider 2. Message 3. Session 4. Producer 5. Consumer 6. Destination import javax.jms.*; public class JMSExample { public static void main(String[] args) { try { ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("myQueue"); MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage("Hello, JMS!"); producer.send(message); MessageConsumer consumer = session.createConsumer(destination); Message receivedMessage = consumer.receive(); if (receivedMessage instanceof TextMessage) { TextMessage textMessage = (TextMessage) receivedMessage; System.out.println("Received message: " + textMessage.getText()); } connection.close(); } catch (JMSException e) { e.printStackTrace(); } } }


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