@Override public void onNewData( ApplicationObject topicSample ) { if( topicSample instanceof Message ) { Message msg = (Message) topicSample; String content = new String( msg.getContent() ); JSONParser parser = new JSONParser(); try { JSONObject object = (JSONObject) parser.parse( content ); String tag = (String) object.get( "tag" ); switch( tag ) { case "SensorData": handleSensorData( object ); break; case "EventData": final String label = (String) object.get( "label" ); final String data = (String) object.get( "data" ); handleEvent( label, data ); break; case "ReplyData": case "ErrorData": handleMessage( tag, object ); break; } } catch( Exception ex ) { System.out.println( ex.getMessage() ); } } }