import javax.jms.*; ConnectionFactory connectionFactory = new com.sun.messaging.ConnectionFactory(); Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("myQueue"); MessageProducer producer = session.createProducer(destination); MessageListener listener = new MessageListener() { public void onMessage(Message message) { try { if (message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; System.out.println("Received message: " + textMessage.getText()); } } catch (JMSException e) { e.printStackTrace(); } } }; MessageConsumer consumer = session.createConsumer(destination); consumer.setMessageListener(listener); TextMessage message = session.createTextMessage(); message.setText("Hello, World!"); producer.send(message);