this.executor = new QueuedExecutor();
   ServerConsumerEndpoint(int id, Channel messageQueue, String queueName,                         ServerSessionEndpoint sessionEndpoint,                         String selector, boolean noLocal, JBossDestination dest)                         throws InvalidSelectorException   {      if (trace) { log.trace("constructing consumer endpoint " + id); }      this.id = id;            this.messageQueue = messageQueue;            this.queueName = queueName;            this.sessionEndpoint = sessionEndpoint;            this.callbackHandler = sessionEndpoint.getConnectionEndpoint().getCallbackHandler();            this.versionToUse = sessionEndpoint.getConnectionEndpoint().getUsingVersion();                  this.noLocal = noLocal;            this.destination = dest;            //TEMP      this.executor = new QueuedExecutor();            //Always start as false - wait for consumer to initiate      this.clientAccepting = false;            this.startStopLock = new Object();            if (selector != null)      {         if (trace) log.trace("creating selector:" + selector);         this.messageSelector = new Selector(selector);         if (trace) log.trace("created selector");      }             this.started = this.sessionEndpoint.getConnectionEndpoint().isStarted();      // adding the consumer to the queue      this.messageQueue.add(this);            // prompt delivery      promptDelivery();      log.debug(this + " constructed");   }