this.deliveryLock = new Object();
this.lock = new ReentrantLock();
   public ServerConsumerDelegate(String id, Channel channel,                                 InvokerCallbackHandler callbackHandler,                                 ServerSessionDelegate sessionEndpoint,                                 String selector, boolean noLocal)      throws InvalidSelectorException   {      log.debug("creating ServerConsumerDelegate[" + id + "]");      this.id = id;      this.channel = channel;      this.sessionEndpoint = sessionEndpoint;      this.callbackHandler = callbackHandler;      this.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.deliveries = new ArrayList();      this.started = sessionEndpoint.connectionEndpoint.started;      this.channel.add(this);      this.deliveryLock = new Object();   }