protected Binding createBinding(String nodeId, String condition, String queueName, long channelId, String filterString, boolean durable) throws Exception
protected Binding createBinding(int nodeId, String condition, String queueName, long channelId, String filterString, boolean durable) throws Exception
   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;   }