From 7a47e63aa9d8650407960503ea897b720100e3b1 Mon Sep 17 00:00:00 2001 From: David Turanski Date: Mon, 22 Aug 2011 18:32:58 -0400 Subject: [PATCH] INT-2074 changed name to queryName --- .../inbound/ContinuousQueryMessageProducer.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/inbound/ContinuousQueryMessageProducer.java b/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/inbound/ContinuousQueryMessageProducer.java index 3572d273b7..a16b38f26b 100644 --- a/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/inbound/ContinuousQueryMessageProducer.java +++ b/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/inbound/ContinuousQueryMessageProducer.java @@ -43,7 +43,7 @@ public class ContinuousQueryMessageProducer extends MessageProducerSupport imple private final String query; private final QueryListenerContainer queryListenerContainer; - private volatile String name; + private volatile String queryName; private boolean durable; /** @@ -60,10 +60,10 @@ public class ContinuousQueryMessageProducer extends MessageProducerSupport imple /** * - * @param name optional query name + * @param queryName optional query name */ - public void setName(String name) { - this.name = name; + public void setQueryName(String queryName) { + this.queryName = queryName; } /** @@ -77,10 +77,10 @@ public class ContinuousQueryMessageProducer extends MessageProducerSupport imple @Override protected void onInit() { super.onInit(); - if (name == null){ + if (queryName == null){ queryListenerContainer.addListener(new CqQueryDefinition(this.query, this, this.durable)); } else { - queryListenerContainer.addListener(new CqQueryDefinition(this.name, this.query, this, this.durable)); + queryListenerContainer.addListener(new CqQueryDefinition(this.queryName, this.query, this, this.durable)); } }