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);            Queue queue;      if (nodeId.equals(this.nodeId))      {         QueuedExecutor executor = (QueuedExecutor)pool.get();                  queue = new PagingFilteredQueue(queueName, channelId, ms, pm, true,                                         true, executor, filter);      }      else      {         throw new IllegalStateException("This is a non clustered post office - should not have bindings from different nodes!");      }            Binding binding = new DefaultBinding(nodeId, condition, queue);            return binding;   }