ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = connectionFactory.createConnection("username", "password"); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("myQueue"); MessageProducer producer = session.createProducer(destination); MessageConsumer consumer = session.createConsumer(destination); TextMessage message = session.createTextMessage("Hello, JMS!"); producer.send(message); Message receivedMessage = consumer.receive(); receivedMessage.acknowledge(); connection.close();