public class GemFireSource extends AbstractModuleFixture<GemFireSource>
label| Constructor and Description |
|---|
GemFireSource(java.lang.String region)
Create a Gemfire Sink module.
|
| 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.
|
label, toStringpublic GemFireSource(java.lang.String region)
region - the name of the region to use for this stream. The region must exist on the server.public GemFireSource useLocator(boolean useLocator)
useLocator - true if using a locator. Default is false.public GemFireSource host(java.lang.String host)
host - the host. Default is localhostpublic GemFireSource port(int port)
port - the portpublic GemFireSource cacheEventExpression(java.lang.String cacheEventExpression)
cacheEventExpression - a SpEL expression evaluating the payloadprotected java.lang.String toDSL()
AbstractModuleFixturefile --dir=xxxx --name=yyyytoDSL in class AbstractModuleFixture<GemFireSource>