@Override
	protected String toDSL() {
		StringBuilder dslBuilder = new StringBuilder();
		dslBuilder.append("gemfire-cq");
		dslBuilder.append(" --useLocator=" + useLocator);
		dslBuilder.append(" --host=" + host);
		dslBuilder.append(" --port=" + port);
		dslBuilder.append(" --query=" + query);

		return dslBuilder.toString();
	}
Set the gemfire server port. Default is 40404

@param port the port
@return this
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/GemFireCQSource.java