private void setPipeliningProperties ( ) { if ( ctx . channel ( ) . attr ( Constants . MAX_RESPONSES_ALLOWED_TO_BE_QUEUED ) . get ( ) == null ) { ctx . channel ( ) . attr ( Constants . MAX_RESPONSES_ALLOWED_TO_BE_QUEUED ) . set ( pipeliningLimit ) ; } if ( ctx . channel ( ) . attr ( Constants . RESPONSE_QUEUE ) . get ( ) == null ) { ctx . channel ( ) . attr ( Constants . RESPONSE_QUEUE ) . set ( holdingQueue ) ; } if ( ctx . channel ( ) . attr ( Constants . NEXT_SEQUENCE_NUMBER ) . get ( ) == null ) { ctx . channel ( ) . attr ( Constants . NEXT_SEQUENCE_NUMBER ) . set ( EXPECTED_SEQUENCE_NUMBER ) ; } if ( ctx . channel ( ) . attr ( Constants . PIPELINING_EXECUTOR ) . get ( ) == null ) { ctx . channel ( ) . attr ( Constants . PIPELINING_EXECUTOR ) . set ( pipeliningGroup ) ; } }
Set pipeline related properties . These should be set only once per connection .