if (log.isTraceEnabled()) { log.trace("createConnectionConsumer"); }
if (trace) { log.trace("createConnectionConsumer"); }
   public Object handleCreateConnectionConsumer(Invocation invocation) throws Throwable   {      if (log.isTraceEnabled()) { log.trace("createConnectionConsumer"); }            MethodInvocation mi = (MethodInvocation)invocation;            Destination dest = (Destination)mi.getArguments()[0];      String subscriptionName = (String)mi.getArguments()[1];      String messageSelector = (String)mi.getArguments()[2];      ServerSessionPool sessionPool = (ServerSessionPool)mi.getArguments()[3];      int maxMessages = ((Integer)mi.getArguments()[4]).intValue();            ConnectionConsumer cc =         new JBossConnectionConsumer((ConnectionDelegate)mi.getTargetObject(), dest, subscriptionName,                                     messageSelector, sessionPool, maxMessages);              return cc;          }