this.lock = new ReentrantLock(); }
}
   ServerConsumerEndpoint(String id, Channel channel,                                 InvokerCallbackHandler callbackHandler,                                 ServerSessionEndpoint 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.lock = new ReentrantLock();         }