this.subscription = subscription;
   public ServerConsumerDelegate(String id, Channel destination,                                 InvokerCallbackHandler callbackHandler,                                 ServerSessionDelegate sessionEndpoint,                                 String selector,                                 boolean noLocal,                                 DurableSubscriptionHolder subscription)      throws InvalidSelectorException   {      if (log.isTraceEnabled()) log.trace("Creating ServerConsumerDelegate:" + id + ", noLocal:" + noLocal);      this.id = id;      this.destination = destination;      this.sessionEndpoint = sessionEndpoint;      this.callbackHandler = callbackHandler;      threadPool = sessionEndpoint.getConnectionEndpoint().getServerPeer().getThreadPool();      this.noLocal = noLocal;      if (selector != null)      {         if (log.isTraceEnabled()) log.trace("creating selector:" + selector);         this.messageSelector = new Selector(selector);         if (log.isTraceEnabled()) log.trace("created selector");      }      this.subscription = subscription;      deliveries = new HashMap();          }