MessageListener msgListener = new MessageListener(){ public void onMessage(Object message) { System.out.println("receive msg : " + message); } };