Uses of Class
adams.flow.standalone.RedisConnection
-
-
Uses of RedisConnection in adams.flow.sink
Fields in adams.flow.sink declared as RedisConnection Modifier and Type Field Description protected RedisConnection
RedisSink. m_Connection
the current connection. -
Uses of RedisConnection in adams.flow.sink.redisaction
Methods in adams.flow.sink.redisaction with parameters of type RedisConnection Modifier and Type Method Description String
AbstractRedisAction. check(RedisConnection connection, Object o)
For checking the state before executing the action.protected abstract String
AbstractRedisAction. doExecute(RedisConnection connection, Object o)
Performs the action on the specified object.protected String
Null. doExecute(RedisConnection connection, Object o)
Performs the action on the specified object.protected String
Publish. doExecute(RedisConnection connection, Object o)
Performs the action on the specified object.protected String
Set. doExecute(RedisConnection connection, Object o)
Performs the action on the specified object.String
AbstractRedisAction. execute(RedisConnection connection, Object o)
Performs the action on the specified object. -
Uses of RedisConnection in adams.flow.source
Fields in adams.flow.source declared as RedisConnection Modifier and Type Field Description protected RedisConnection
RedisSource. m_Connection
the current connection. -
Uses of RedisConnection in adams.flow.source.redisaction
Methods in adams.flow.source.redisaction with parameters of type RedisConnection Modifier and Type Method Description String
AbstractRedisAction. check(RedisConnection connection)
For checking the state before executing the action.protected abstract Object
AbstractRedisAction. doExecute(RedisConnection connection, adams.core.MessageCollection errors)
Performs the action.protected Object
Get. doExecute(RedisConnection connection, adams.core.MessageCollection errors)
Performs the action.protected Object
Null. doExecute(RedisConnection connection, adams.core.MessageCollection errors)
Performs the action.Object
AbstractRedisAction. execute(RedisConnection connection, adams.core.MessageCollection errors)
Performs the action on the specified object. -
Uses of RedisConnection in adams.flow.standalone.rats.input
Fields in adams.flow.standalone.rats.input declared as RedisConnection Modifier and Type Field Description protected RedisConnection
RedisAction. m_Connection
the redis connection to use.protected RedisConnection
RedisSubscribe. m_Connection
the redis connection to use. -
Uses of RedisConnection in adams.flow.standalone.rats.output
Fields in adams.flow.standalone.rats.output declared as RedisConnection Modifier and Type Field Description protected RedisConnection
RedisAction. m_Connection
the redis connection to use.protected RedisConnection
RedisPublish. m_Connection
the redis connection to use. -
Uses of RedisConnection in adams.flow.transformer
Fields in adams.flow.transformer declared as RedisConnection Modifier and Type Field Description protected RedisConnection
RedisTransformer. m_Connection
the current connection. -
Uses of RedisConnection in adams.flow.transformer.redisaction
Methods in adams.flow.transformer.redisaction with parameters of type RedisConnection Modifier and Type Method Description String
AbstractRedisAction. check(RedisConnection connection, Object o)
For checking the state before executing the action.protected abstract Object
AbstractRedisAction. doExecute(RedisConnection connection, Object o, adams.core.MessageCollection errors)
Performs the action.protected Object
BroadcastAndListen. doExecute(RedisConnection connection, Object o, adams.core.MessageCollection errors)
Performs the action.protected Object
PassThrough. doExecute(RedisConnection connection, Object o, adams.core.MessageCollection errors)
Performs the action.Object
AbstractRedisAction. execute(RedisConnection connection, Object o, adams.core.MessageCollection errors)
Performs the action on the specified object.
-