private void processSyncMessageChunk ( CommsByteBuffer buffer , Conversation conversation , boolean connectionMessage ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( this , tc , "processSyncMessageChunk" , new Object [ ] { buffer , conversation , connectionMessage } ) ; // First get the ConnectionProxy for this conversation ClientConversationState convState = ( ClientConversationState ) conversation . getAttachment ( ) ; ConnectionProxy connProxy = ( ConnectionProxy ) convState . getSICoreConnection ( ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( this , tc , "Found connection: " , connProxy ) ; // Now read the connection object Id buffer . getShort ( ) ; // BIT16 ConnectionObjId if ( connectionMessage ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( this , tc , "Adding message part directly to connection" ) ; connProxy . addMessagePart ( buffer ) ; } else { short consumerSessionId = buffer . getShort ( ) ; // BIT16 ConsumerSessionId if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( this , tc , "Consumer Session Id:" , "" + consumerSessionId ) ; // Now simply pass the message buffer off to the consumer ConsumerSessionProxy consumer = connProxy . getConsumerSessionProxy ( consumerSessionId ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( this , tc , "Found consumer:" , consumer ) ; consumer . addMessagePart ( buffer ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( this , tc , "processSyncMessageChunk" ) ; }
Processes a chunk received from a synchronous message .