public void setAsynchConsumerCallback(int requestNumber,
                                         int maxActiveMessages,
                                         long messageLockExpiry,
                                         int batchsize,
                                         OrderingContext orderContext,
                                         boolean stoppable,                                             //SIB0115d.comms
                                         int maxSequentialFailures,
                                         long hiddenMessageDelay)                                       //SIB0115d.comms
   {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "setAsynchConsumerCallback",
                                           new Object[]
                                           {
                                              requestNumber,
                                              maxActiveMessages,
                                              messageLockExpiry,
                                              batchsize,
                                              orderContext,
                                              stoppable,                                                //SIB0115d.comms
                                              maxSequentialFailures,                                    //SIB0115d.comms
                                              hiddenMessageDelay
                                           });

      try
      {
         // Note: per the design document, a readahead consumer callback should always be created
         // with a batch size of 1 - this case should never happen.
         if (batchsize > 1)
         {
            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
            {
               SibTr.debug(this, tc, "*** The batch size submitted to CATProxyConsumer was great than 1");
            }
         }

         getConsumerSession().registerAsynchConsumerCallback(callback,
                                                             maxActiveMessages,
                                                             messageLockExpiry,
                                                             batchsize,
                                                             null);
      }
      catch (Exception e)
      {
         // No FFDC code needed

         // Any exceptions we get, throw back to the caller (us) so that
         // we are aware that something went wrong
         RuntimeException r = new RuntimeException(e.getMessage(), e);
         throw r;
      }

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc, "setAsynchConsumerCallback");
   }
public void setAsynchConsumerCallback ( int requestNumber , int maxActiveMessages , long messageLockExpiry , int batchsize , OrderingContext orderContext , boolean stoppable , int maxSequentialFailures , long hiddenMessageDelay ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "setAsynchConsumerCallback" , new Object [ ] { requestNumber , maxActiveMessages , messageLockExpiry , batchsize , orderContext , stoppable , maxSequentialFailures , hiddenMessageDelay } ) ; try { if ( batchsize > 1 ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) { SibTr . debug ( this , tc , "*** The batch size submitted to CATProxyConsumer was great than 1" ) ; } } getConsumerSession ( ) . registerAsynchConsumerCallback ( callback , maxActiveMessages , messageLockExpiry , batchsize , null ) ; } catch ( Exception e ) { RuntimeException r = new RuntimeException ( e . getMessage ( ) , e ) ; throw r ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( this , tc , "setAsynchConsumerCallback" ) ; }
Sets the async consumer for a read ahead session.

@param requestNumber
@param maxActiveMessages
@param messageLockExpiry
@param batchsize
@param orderContext This paramter is ignored for read ahead consumers.
@param stoppable (ignored)
@param maxSequentialFailures (ignored)
@param hiddenMessageDelay