log.debug("creating ConsumerEndpoint[" + id + "]");
if (trace) { log.trace("creating consumer endpoint " + id); }
   protected ServerConsumerEndpoint(int id, Channel channel,                                    ServerSessionEndpoint sessionEndpoint,                                    String selector, boolean noLocal)                                    throws InvalidSelectorException   {      log.debug("creating ConsumerEndpoint[" + id + "]");            this.id = id;      this.channel = channel;      this.sessionEndpoint = sessionEndpoint;      this.threadPoolDelegate =         sessionEndpoint.getConnectionEndpoint().getServerPeer().getThreadPoolDelegate();      this.noLocal = noLocal;            if (selector != null)      {         if (trace) log.trace("creating selector:" + selector);         this.messageSelector = new Selector(selector);         if (trace) log.trace("created selector");      }            this.deliveries = new LinkedHashMap();      this.started = this.sessionEndpoint.getConnectionEndpoint().isStarted();      this.channel.add(this);         }