holder.msg, ackMode, holder.maxDeliveries);
holder.msg, ackMode, holder.maxDeliveries, holder.connectionConsumerDelegate);
   public Object handleRun(Invocation invocation) throws Throwable   {      if (trace) { log.trace("run()"); }            MethodInvocation mi = (MethodInvocation)invocation;                  SessionDelegate del = (SessionDelegate)mi.getTargetObject();            int ackMode = getSessionState(invocation).getAcknowledgeMode();      while (msgs.size() > 0)      {         AsfMessageHolder holder = (AsfMessageHolder)msgs.removeFirst();         if (trace) { log.trace("sending " + holder.msg + " to the message listener" ); }                  MessageCallbackHandler.callOnMessage(del, sessionListener, holder.consumerID,                                              holder.channelID, false,                                              holder.msg, ackMode, holder.maxDeliveries);                                }            return null;   }