How to listen activemq and pop-up a messagebox while there has a new message in mq?

asked 2014-02-21 11:18:24 +0800

wch10610
1

I'm trying to listen activemq and pop-up a messagbox while there has a new message in MQ. Although It shows there has a new message in MQ and my controller can print that message on log, the messagebox doesn't show up. How can I fix this probelm.

bellow is my code:

public class A0102Controller extends SelectorComposer<component> implements MessageListener{

private static final long serialVersionUID = -7823022704116547799L;

public void doAfterCompose(Component comp) throws Exception {

    super.doAfterCompose(comp);

    System.out.println("doAfterCompose...");

    startListening();

}

public void startListening() {

    System.out.println("Subscriber.startListening()");

    try {
        ConnectionFactory factory = getJmsConnectionFactory();
        Connection connection = factory.createConnection();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Topic topic = session.createTopic("ServerMsg");
        MessageConsumer consumer = session.createConsumer(topic);
        consumer.setMessageListener(this);
        connection.start();
    } catch (JMSException e) {
        System.err.println("Exception occurred: " + e.toString());
    }
}

/**
 * Use the ActiveMQConnectionFactory to get a JMS ConnectionFactory. In an
 * enterprise application this would normally be accessed through JNDI.
 */
public static ConnectionFactory getJmsConnectionFactory()
        throws JMSException {
    String user = ActiveMQConnection.DEFAULT_USER;
    String password = ActiveMQConnection.DEFAULT_PASSWORD;
    String url = ActiveMQConnection.DEFAULT_BROKER_URL;

    return new ActiveMQConnectionFactory(user, password, url);
}

@Override
public void onMessage(Message message) {

    if (message instanceof TextMessage) {
        TextMessage txtMsg = (TextMessage) message;
        try {
            String msg = txtMsg.getText();              
            System.out.println("Server Msg : " + msg);
            Messagebox.show("Time is up!!", "Warning", Messagebox.OK, Messagebox.EXCLAMATION);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

}