messageSelector = new Selector(selector);
if (log.isTraceEnabled()) log.trace("Creating selector:" + selector); this.messageSelector = new Selector(selector); if (log.isTraceEnabled()) log.trace("Created selector");
   public ServerConsumerDelegate(String id, AbstractDestination destination,                                 InvokerCallbackHandler callbackHandler,                                 ServerSessionDelegate sessionEndpoint,                                 String selector,                                 boolean noLocal,                                 DurableSubscriptionHolder subscription)      throws JMSException   {      this.id = id;      this.destination = destination;      this.sessionEndpoint = sessionEndpoint;      this.callbackHandler = callbackHandler;      threadPool = sessionEndpoint.getConnectionEndpoint().getServerPeer().getThreadPool();      this.noLocal = noLocal;      if (selector != null)      {         messageSelector = new Selector(selector);      }      this.subscription = subscription;   }