if (nodeId.equals(this.nodeId))
if (nodeId == this.nodeId)
   protected Binding createBinding(String nodeId, String condition, String queueName, long channelId, String filterString, boolean durable) throws Exception   {                  Filter filter = filterFactory.createFilter(filterString);            log.info("Created binding");            Queue queue;      if (nodeId.equals(this.nodeId))      {         QueuedExecutor executor = (QueuedExecutor)pool.get();                  log.info("created local clustered queue");                  queue = new LocalClusteredQueue(this, nodeId, queueName, channelId, ms, pm, true,                                         durable, executor, filter, tr);      }      else      {         log.info("created remote queue stub");                  queue = new RemoteQueueStub(nodeId, queueName, channelId, durable, pm, filter);      }            Binding binding = new DefaultBinding(nodeId, condition, queue);            return binding;   }