if (binding.getNodeId().equals(this.nodeId))
if (binding.getNodeId() == this.nodeId)
   private void processStateBytes(byte[] bytes) throws Exception   {      log.info("Receiving state from group...");            SharedState state = new SharedState();            StreamUtils.fromBytes(state, bytes);            nameMaps.clear();            conditionMap.clear();                       List bindings = state.getBindings();            Iterator iter = bindings.iterator();            while (iter.hasNext())      {         BindingInfo info = (BindingInfo)iter.next();                  Binding binding = this.createBinding(info.getNodeId(), info.getCondition(), info.getQueueName(), info.getChannelId(), info.getFilterString(), info.isDurable());                  if (binding.getNodeId().equals(this.nodeId))         {            //We deactivate if this is one of our own bindings - it can only            //be one of our own durable bindings - and since state is retrieved before we are fully started            //then the sub hasn't been deployed so must be deactivated                        binding.getQueue().deactivate();                     }                     addBinding(binding);               }            this.nodeIdAddressMap.clear();            this.nodeIdAddressMap.putAll(state.getNodeIdAddressMap());   }