public class QpidExample {

    private static String ACTIVEMQ_BROKER_URL = "amqp://localhost:6501";
    //private static String ARTEMIS_BROKER_URL = "amqp://localhost:6502";

    public static void main(final String[] args) throws Exception {

        ConnectionFactory producerCF = new JmsConnectionFactory(ACTIVEMQ_BROKER_URL);

        try (Connection connection = producerCF.createConnection();
             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) {

            Topic topic = session.createTopic("SOME_PREFIX.TOPIC_NAME.test");

            try (MessageProducer producer = session.createProducer(topic)) {
                producer.setDeliveryMode(DeliveryMode.PERSISTENT);
                TextMessage message = session.createTextMessage("This is a text message");
                System.out.println("Sent message: " + message.getText());
                producer.send(message);
            }
        }

        ConnectionFactory consumerCF = new JmsConnectionFactory(ACTIVEMQ_BROKER_URL);
        Connection connection = consumerCF.createConnection();
        connection.setClientID("abc");
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        Topic topic = session.createTopic("SOME_PREFIX.TOPIC_NAME.#");

        try(TopicSubscriber subscriber = session.createDurableSubscriber(topic, "SUB1235")) {
            connection.start();
            Message messageReceived = subscriber.receive();
            System.out.println("Received message: " + messageReceived);
        }
    }
}