question: public void disconnected ( MqttException reason ) { final String methodName = "disconnected" ; log . fine ( CLASS_NAME , methodName , "633" , new Object [ ] { reason } ) ; this . connected = false ; try { if ( cleanSession ) { clearState ( ) ; } pendingMessages . clear ( ) ; pendingFlows . clear ( ) ; synchronized ( pingOutstandingLock ) { pingOutstanding = 0 ; } } catch ( MqttException e ) { } }
target:  Called when the client has been disconnected from the broker.