org.springframework.xd.test.fixtures

Class GemFireServerSink

java.lang.Object

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

org.springframework.xd.test.fixtures.GemFireServerSink

public class GemFireServerSink
extends AbstractModuleFixture<GemFireServerSink>

Create a gemfire-server or gemfire-json-server sink.

Author:

David Turanski

Field Summary

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

label

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
GemFireServerSink	host(java.lang.String host) Set the host name
GemFireServerSink	json(boolean json) Configure this to use GemFire JSON representation, i.e., create a gemfire-json-server sink.
GemFireServerSink	keyExpression(java.lang.String keyExpression) Set the cache key.
GemFireServerSink	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
GemFireServerSink	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

GemFireServerSink

public GemFireServerSink(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

json

public GemFireServerSink json(boolean json)

Configure this to use GemFire JSON representation, i.e., create a gemfire-json-server sink.

Parameters:

json - true if using gemfire-json-server, false for gemfire-server.

Returns:

this

useLocator

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

Set the host name

Parameters:

host - the host. Default is localhost

Returns:

this

port

public GemFireServerSink port(int port)

Set the gemfire server port. Default is 40404

Parameters:

port - the port

Returns:

this

keyExpression

public GemFireServerSink keyExpression(java.lang.String keyExpression)

Set the cache key. Defaults to stream name

Parameters:

keyExpression - 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<GemFireServerSink>