if (!queue.getNodeId().equals(this.nodeId))
if (queue.getNodeId() != this.nodeId)
   public Binding bindClusteredQueue(String condition, LocalClusteredQueue queue) throws Exception   {                 log.info(this.nodeId + " binding clustered queue: " + queue + " with condition: " + condition);            if (!queue.getNodeId().equals(this.nodeId))      {         throw new IllegalArgumentException("Queue node id does not match office node id");      }            Binding binding = (Binding)super.bindQueue(condition, queue);            BindRequest request =         new BindRequest(nodeId, queue.getName(), condition, queue.getFilter() == null ? null : queue.getFilter().getFilterString(),                         binding.getQueue().getChannelID(), queue.isRecoverable());            syncSendRequest(request);              return binding;   }