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

INT-2075 made changes for the new SGF class names

Browse Source
This commit is contained in:
David Turanski
2011-08-26 15:40:26 -04:00
committed by Mark Fisher
parent d1ece40ddc
commit 9366c56328
6 changed files with 26 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/inbound/ContinuousQueryMessageProducerTests.java
View File

@@ -17,7 +17,7 @@ import static org.mockito.Mockito.mock;
import org.junit.Before;
import org.junit.Test;
import org.springframework.data.gemfire.listener.QueryListenerContainer;
import org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer;
import org.springframework.integration.Message;
import org.springframework.integration.MessagingException;
import org.springframework.integration.channel.DirectChannel;
@@ -33,7 +33,7 @@ import com.gemstone.gemfire.cache.query.internal.CqQueryImpl;
* @since 2.1
*/
public class ContinuousQueryMessageProducerTests {
QueryListenerContainer queryListenerContainer;
ContinuousQueryListenerContainer queryListenerContainer;
ContinuousQueryMessageProducer cqMessageProducer;
@@ -41,7 +41,7 @@ public class ContinuousQueryMessageProducerTests {
@Before
public void setUp() {
queryListenerContainer = mock(QueryListenerContainer.class);
queryListenerContainer = mock(ContinuousQueryListenerContainer.class);
cqMessageProducer = new ContinuousQueryMessageProducer(queryListenerContainer, "");
DirectChannel outputChannel = new DirectChannel();
cqMessageProducer.setOutputChannel(outputChannel);

6
spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/inbound/CqInboundChannelAdapterTests-context.xml
View File

@@ -19,18 +19,18 @@
<gfe:client-region id="test" cache-ref="client-cache" pool-name="client-pool" data-policy="EMPTY"/>
<bean id="queryListenerContainer" class="org.springframework.data.gemfire.listener.QueryListenerContainer">
<bean id="queryListenerContainer" class="org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer">
<property name="cache" ref="client-cache"/>
</bean>
<int-gfe:cq-inbound-channel-adapter query-listener-container="queryListenerContainer"
<int-gfe:cq-inbound-channel-adapter cq-listener-container="queryListenerContainer"
query="select * from /test" channel="outputChannel1" durable="true"/>
<int:channel id="outputChannel1">
<int:queue/>
</int:channel>
<int-gfe:cq-inbound-channel-adapter query-listener-container="queryListenerContainer"
<int-gfe:cq-inbound-channel-adapter cq-listener-container="queryListenerContainer"
query="select * from /test" channel="outputChannel2" expression="newValue" query-events="CREATED"/>