org.springframework.xd.test.fixtures

Class GemFireCQSource

java.lang.Object

org.springframework.xd.test.fixtures.AbstractModuleFixture<GemFireCQSource>

org.springframework.xd.test.fixtures.GemFireCQSource

public class GemFireCQSource
extends AbstractModuleFixture<GemFireCQSource>

Create a gemfire CQ (continuous query) source.

Author:

David Turanski

Field Summary

Fields inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label

Constructor Summary

Constructors

Constructor and Description
GemFireCQSource(java.lang.String query) Create a Gemfire Sink module.

Method Summary

Methods

Modifier and Type	Method and Description
GemFireCQSource	host(java.lang.String host) Set the host name
GemFireCQSource	port(int port) Set the gemfire server port.
protected java.lang.String	toDSL() Returns a representation of the module suitable for inclusion in a stream definition, e.g. file --dir=xxxx --name=yyyy
GemFireCQSource	useLocator(boolean useLocator) Set the host and port to reference a Gemfire locator instead of a server node.

Methods inherited from class org.springframework.xd.test.fixtures.AbstractModuleFixture

label, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GemFireCQSource

public GemFireCQSource(java.lang.String query)

Create a Gemfire Sink module.

Parameters:

query - the OQL query string.

Method Detail

useLocator

public GemFireCQSource useLocator(boolean useLocator)

Set the host and port to reference a Gemfire locator instead of a server node.

Parameters:

useLocator - true if using a locator. Default is false.

Returns:

this

host

public GemFireCQSource host(java.lang.String host)

Set the host name

Parameters:

host - the host. Default is localhost

Returns:

this

port

public GemFireCQSource port(int port)

Set the gemfire server port. Default is 40404

Parameters:

port - the port

Returns:

this

toDSL

protected java.lang.String toDSL()

Description copied from class: AbstractModuleFixture

Returns a representation of the module suitable for inclusion in a stream definition, e.g. file --dir=xxxx --name=yyyy

Specified by:

toDSL in class AbstractModuleFixture<GemFireCQSource>