static void rcvRequestMsgs ( CommsByteBuffer request , Conversation conversation , int requestNumber , boolean allocatedFromBufferPool , boolean partOfExchange ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "rcvRequestMsgs" , new Object [ ] { request , conversation , "" + requestNumber , "" + allocatedFromBufferPool } ) ; short connectionObjectID = request . getShort ( ) ; // BIT16 ConnectionObjectId short consumerObjectID = request . getShort ( ) ; // BIT16 SyncConsumerSessionId int receivedBytes = request . getInt ( ) ; // BIT32 ReceivedBytes int requestedBytes = request . getInt ( ) ; // BIT32 RequestedBytes if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) { SibTr . debug ( tc , "connectionObjectID" , connectionObjectID ) ; SibTr . debug ( tc , "consumerObjectID" , consumerObjectID ) ; SibTr . debug ( tc , "receivedBytes" , receivedBytes ) ; SibTr . debug ( tc , "requestedBytes" , requestedBytes ) ; } CATMainConsumer mainConsumer = ( ( CATMainConsumer ) ( ( ConversationState ) conversation . getAttachment ( ) ) . getObject ( consumerObjectID ) ) ; mainConsumer . requestMsgs ( requestNumber , receivedBytes , requestedBytes ) ; request . release ( allocatedFromBufferPool ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "rcvRequestMsgs" ) ; }
Request messages for this consumer .