public void run() throws JMSException {

        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(url);

        connection = factory.createConnection();

        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        topic = session.createTopic("topictest.messages");

        control = session.createTopic("topictest.control");



        MessageConsumer consumer = session.createConsumer(topic);

        consumer.setMessageListener(this);



        connection.start();



        producer = session.createProducer(control);

        System.out.println("Waiting for messages...");

    }