public GemFireCQSource gemFireCqSource(String query) {
		return new GemFireCQSource(query).host(xdEnvironment.getGemfireHost()).port(xdEnvironment.getGemfirePort());
	}
Constructs a new {@link org.springframework.xd.test.fixtures.GemFireCQSource}.

@param query the OQL query string bound to this source
@return a new instance of {@link org.springframework.xd.test.fixtures.GemFireCQSource}.
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/fixtures/Sources.java