static void rcvStartSess ( CommsByteBuffer request , Conversation conversation , int requestNumber , boolean allocatedFromBufferPool , boolean partOfExchange , boolean restart ) //471642 { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "rcvStartSess" , new Object [ ] { request , conversation , requestNumber , allocatedFromBufferPool , restart //471642 } ) ; short connectionObjectID = request . getShort ( ) ; // BIT16 ConnectionObjectId short consumerObjectID = request . getShort ( ) ; // BIT16 SyncConsumerSessionId if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) { SibTr . debug ( tc , "connectionObjectID" , connectionObjectID ) ; SibTr . debug ( tc , "consumerObjectID" , consumerObjectID ) ; } CATMainConsumer mainConsumer = ( ( CATMainConsumer ) ( ( ConversationState ) conversation . getAttachment ( ) ) . getObject ( consumerObjectID ) ) ; mainConsumer . start ( requestNumber , true , partOfExchange , null , restart ) ; //471642 request . release ( allocatedFromBufferPool ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "rcvStartSess" ) ; }
Start the Synchronous Consumer Session provided by the client .