new ActiveMQConnectionFactory("tcp://localhost:61616"); if (receivedMessage instanceof TextMessage) { TextMessage textMessage = (TextMessage) receivedMessage; System.out.println("Received message: " + textMessage.getText()); }