ServerConsumerEndpoint(int id, Channel channel, ServerSessionEndpoint sessionEndpoint, String selector, boolean noLocal) throws InvalidSelectorException
protected ServerConsumerEndpoint(int id, Channel channel, ServerSessionEndpoint sessionEndpoint, String selector, boolean noLocal) throws InvalidSelectorException
   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 = sessionEndpoint.connectionEndpoint.started;      this.channel.add(this);         }