public class RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState>
BaseStateUpdater implementation for Redis Cluster environment.
AbstractRedisStateUpdater,
Serialized FormadditionalKey, dataType, expireIntervalSec| Constructor and Description |
|---|
RedisClusterStateUpdater(RedisStoreMapper storeMapper)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
updateStatesToRedis(RedisClusterState redisClusterState,
Map<String,String> keyToValue)
Updates (key, value) pairs to Redis.
|
RedisClusterStateUpdater |
withExpire(int expireIntervalSec)
Sets expire (time to live) if needed.
|
setExpireInterval, updateStatecleanup, preparepublic RedisClusterStateUpdater(RedisStoreMapper storeMapper)
Constructor.
storeMapper - mapper for storingpublic RedisClusterStateUpdater withExpire(int expireIntervalSec)
Sets expire (time to live) if needed.
expireIntervalSec - time to live in secondsprotected void updateStatesToRedis(RedisClusterState redisClusterState, Map<String,String> keyToValue)
Updates (key, value) pairs to Redis.
updateStatesToRedis in class AbstractRedisStateUpdater<RedisClusterState>redisClusterState - State for handling querykeyToValue - (key, value) pairsCopyright © 2021 The Apache Software Foundation. All rights reserved.