TestListener.java |
package org.mockejb.jms.test; import javax.jms.*; public class TestListener implements MessageListener { public void onMessage(Message msg) { try { if (msg instanceof TextMessage) { System.out.println("Received TextMessage: " + ((TextMessage)msg).getText()); } else { System.out.println("Received Message: " + msg); } } catch (JMSException ex) { throw new RuntimeException("JMSException thrown: " + ex.getMessage()); } } }