holder.connectionConsumerDelegate = connectionConsumerDelegate;
   public Object handleAddAsfMessage(Invocation invocation) throws Throwable   {      if (trace) { log.trace("addAsfMessage()"); }            MethodInvocation mi = (MethodInvocation)invocation;            // Load the session with a message to be processed during a subsequent call to run()      MessageProxy m = (MessageProxy)mi.getArguments()[0];      int theConsumerID = ((Integer)mi.getArguments()[1]).intValue();      long channelID = ((Long)mi.getArguments()[2]).longValue();      int maxDeliveries = ((Integer)mi.getArguments()[3]).intValue();            if (m == null)      {         throw new IllegalStateException("Cannot add a null message to the session");      }      AsfMessageHolder holder = new AsfMessageHolder();      holder.msg = m;      holder.consumerID = theConsumerID;      holder.channelID = channelID;      holder.maxDeliveries = maxDeliveries;            msgs.add(holder);      return null;   }