private AmqpChannel closeOkChannel ( ) { if ( readyState == ReadyState . CLOSED ) { // If the channel has been closed, just bail. return this ; } Object [ ] args = { } ; WrappedByteBuffer bodyArg = null ; HashMap < String , Object > headersArg = null ; String methodName = "closeOkChannel" ; String methodId = "20" + "41" ; AmqpMethod amqpMethod = MethodLookup . LookupMethod ( methodId ) ; ; Object [ ] arguments = { this , amqpMethod , this . id , args , bodyArg , headersArg } ; asyncClient . enqueueAction ( methodName , "channelWrite" , arguments , null , null ) ; return this ; }
Confirms to the peer that a flow command was received and processed .