MessageProducer producer = session.createProducer(destination); producer.send(message); MessageConsumer consumer = session.createConsumer(destination); Message message = consumer.receive(); String url = "tcp://localhost:61616"; String username = "admin"; String password = "password"; ConnectionFactory factory = new ActiveMQConnectionFactory(url); Connection connection = factory.createConnection(username, password); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("example.queue"); MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage("Hello, World!"); producer.send(message);