public void invoke ( ) { assert state == State . READ_FRAME_COMPLETE : "Invoke called in invalid state: " + state ; TTransport inTrans = getInputTransport ( ) ; TProtocol inProt = thriftFactories . inputProtocolFactory . getProtocol ( inTrans ) ; TProtocol outProt = thriftFactories . outputProtocolFactory . getProtocol ( getOutputTransport ( ) ) ; try { thriftFactories . processorFactory . getProcessor ( inTrans ) . process ( inProt , outProt ) ; responseReady ( ) ; return ; } catch ( TException te ) { logger . warn ( "Exception while invoking!" , te ) ; } catch ( Throwable t ) { logger . error ( "Unexpected throwable while invoking!" , t ) ; } // This will only be reached when there is a throwable. state = State . AWAITING_CLOSE ; changeSelectInterests ( ) ; }
Actually invoke the method signified by this Message .