void function ( Throwable arg0 ) { log . error ( "srini_string" , arg0 ) ; }
handle losing connection with the server . here we just print it to the test console . concode_field_sep List<MqttMessage> receivedMessages concode_elem_sep String lastTopicReceived concode_elem_sep Log log concode_elem_sep boolean saveMessages concode_elem_sep int sentMessageCount concode_elem_sep int receivedMessageCount concode_field_sep List<MqttMessage> getReceivedMessages concode_elem_sep void messageArrived concode_elem_sep int getSentMessageCount concode_elem_sep String getLastTopicReceived concode_elem_sep void incrementReceivedMessageCount concode_elem_sep void incrementSentMessageCount concode_elem_sep int getReceivedMessageCount concode_elem_sep void deliveryComplete