import javax.jms.*; import javax.naming.InitialContext; import javax.naming.NamingException; public class JMSExample { public static void main(String[] args) throws NamingException, JMSException { InitialContext context = new InitialContext(); ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("jms/ConnectionFactory"); Connection connection = connectionFactory.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!"); producer.send(message); MessageConsumer consumer = session.createConsumer(queue); Message receivedMessage = consumer.receive(); if (receivedMessage instanceof TextMessage) { TextMessage receivedTextMessage = (TextMessage) receivedMessage; System.out.println("Received message: " + receivedTextMessage.getText()); } connection.close(); } }