org.springframework.xd.test.fixtures

Class GemFireSource

java.lang.Object

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

org.springframework.xd.test.fixtures.GemFireSource

public class GemFireSource
extends AbstractModuleFixture<GemFireSource>

Create a gemfire source

Author:

David Turanski

Field Summary

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

label

Constructor Summary

Constructors

Constructor and Description
GemFireSource(java.lang.String region) Create a Gemfire Sink module.

Method Summary

Methods

Modifier and Type	Method and Description
GemFireSource	cacheEventExpression(java.lang.String cacheEventExpression) Set the cache key.
GemFireSource	host(java.lang.String host) Set the host name
GemFireSource	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
GemFireSource	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

GemFireSource

public GemFireSource(java.lang.String region)

Create a Gemfire Sink module.

Parameters:

region - the name of the region to use for this stream. The region must exist on the server.

Method Detail

useLocator

public GemFireSource 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 GemFireSource host(java.lang.String host)

Set the host name

Parameters:

host - the host. Default is localhost

Returns:

this

port

public GemFireSource port(int port)

Set the gemfire server port. Default is 40404

Parameters:

port - the port

Returns:

this

cacheEventExpression

public GemFireSource cacheEventExpression(java.lang.String cacheEventExpression)

Set the cache key. Defaults to stream name

Parameters:

cacheEventExpression - a SpEL expression evaluating the payload

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<GemFireSource>