@Deprecated public class RedisDBSClusterInvalidator extends Object implements DBSClusterInvalidator
DBSClusterInvalidator
. Use a single channel pubsub to send invalidations. Use an HSET
to register nodes, only for debug purpose so far.Modifier and Type | Field and Description |
---|---|
protected static String |
CLUSTER_NODES_KEY
Deprecated.
|
protected static String |
INVALIDATION_CHANNEL
Deprecated.
|
protected static String |
LAST_INVAL_FIELD
Deprecated.
|
protected String |
namespace
Deprecated.
|
protected String |
nodeId
Deprecated.
|
protected static String |
PREFIX
Deprecated.
|
protected DBSInvalidations |
receivedInvals
Deprecated.
|
protected RedisExecutor |
redisExecutor
Deprecated.
|
protected String |
repositoryName
Deprecated.
|
protected static String |
STARTED_FIELD
Deprecated.
|
protected String |
startedDateTime
Deprecated.
|
protected Thread |
subscriberThread
Deprecated.
|
protected static int |
TIMEOUT_REGISTER_SECOND
Deprecated.
|
protected static long |
TIMEOUT_SUBSCRIBE_SECOND
Deprecated.
|
Constructor and Description |
---|
RedisDBSClusterInvalidator()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
Closes this cluster invalidator and releases resources.
|
protected void |
createSubscriberThread()
Deprecated.
|
protected String |
getChannelName()
Deprecated.
|
protected String |
getCurrentDateTime()
Deprecated.
|
protected String |
getNodeKey()
Deprecated.
|
void |
initialize(String nodeId,
String repositoryName)
Deprecated.
Initializes the cluster invalidator.
|
DBSInvalidations |
receiveInvalidations()
Deprecated.
Receives invalidations from other cluster nodes.
|
protected void |
registerNode()
Deprecated.
|
void |
sendInvalidations(DBSInvalidations invals)
Deprecated.
Sends invalidations to other cluster nodes.
|
protected void |
subscribeToInvalidationChannel()
Deprecated.
|
protected void |
unsubscribeToInvalidationChannel()
Deprecated.
|
protected static final String PREFIX
protected static final String INVALIDATION_CHANNEL
protected static final String CLUSTER_NODES_KEY
protected static final int TIMEOUT_REGISTER_SECOND
protected static final long TIMEOUT_SUBSCRIBE_SECOND
protected static final String STARTED_FIELD
protected static final String LAST_INVAL_FIELD
protected String repositoryName
protected RedisExecutor redisExecutor
protected DBSInvalidations receivedInvals
protected Thread subscriberThread
protected String startedDateTime
public RedisDBSClusterInvalidator()
public void initialize(String nodeId, String repositoryName)
DBSClusterInvalidator
initialize
in interface DBSClusterInvalidator
nodeId
- the cluster node idrepositoryName
- the repository nameprotected void createSubscriberThread()
protected void subscribeToInvalidationChannel()
protected String getChannelName()
protected void registerNode()
protected String getNodeKey()
public void close()
DBSClusterInvalidator
close
in interface DBSClusterInvalidator
protected void unsubscribeToInvalidationChannel()
public DBSInvalidations receiveInvalidations()
DBSClusterInvalidator
receiveInvalidations
in interface DBSClusterInvalidator
public void sendInvalidations(DBSInvalidations invals)
DBSClusterInvalidator
sendInvalidations
in interface DBSClusterInvalidator
protected String getCurrentDateTime()
Copyright © 2018 Nuxeo. All rights reserved.