Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-2074 changed name to queryName

Browse Source
This commit is contained in:
David Turanski
2011-08-22 18:32:58 -04:00
parent ee8c4e2d69
commit 7a47e63aa9
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/inbound/ContinuousQueryMessageProducer.java
View File

@@ -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));
}
}