public AmqpChannel getBasic ( String queue , boolean noAck ) { Object [ ] args = { 0 , queue , noAck } ; WrappedByteBuffer bodyArg = null ; HashMap < String , Object > headersArg = null ; String methodName = "getBasic" ; String methodId = "60" + "70" ; AmqpMethod amqpMethod = MethodLookup . LookupMethod ( methodId ) ; Object [ ] arguments = { this , amqpMethod , this . id , args , bodyArg , headersArg } ; asyncClient . enqueueAction ( methodName , "channelWrite" , arguments , null , null ) ; return this ; }
Gets messages from the queue and dispatches it to the listener