Package org.redisson.redisnode

Class RedissonBaseNodes

java.lang.Object

org.redisson.redisnode.RedissonBaseNodes

All Implemented Interfaces:

BaseRedisNodes

Direct Known Subclasses:

RedissonClusterNodes, RedissonMasterSlaveNodes, RedissonSingleNode

public class RedissonBaseNodes
extends Object
implements BaseRedisNodes

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
RedissonBaseNodes(ConnectionManager connectionManager, CommandAsyncExecutor commandExecutor)

Method Summary

Modifier and Type	Method	Description
protected RedisNode	getNode(String address, NodeType nodeType)
protected List<RedisNode>	getNodes()
protected <T extends RedisNode> Collection<T>	getNodes(NodeType type)
boolean	pingAll()	Ping all Redis nodes.
boolean	pingAll(long timeout, TimeUnit timeUnit)	Ping all Redis nodes with specified timeout per node

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedissonBaseNodes

public RedissonBaseNodes(ConnectionManager connectionManager,
                         CommandAsyncExecutor commandExecutor)

Method Detail

getNodes

protected <T extends RedisNode> Collection<T> getNodes(NodeType type)

getNode

protected RedisNode getNode(String address,
                            NodeType nodeType)

getNodes

protected List<RedisNode> getNodes()

pingAll

public boolean pingAll(long timeout,
                       TimeUnit timeUnit)

Description copied from interface: BaseRedisNodes

Ping all Redis nodes with specified timeout per node

Specified by:

pingAll in interface BaseRedisNodes

Returns:

true if all nodes replied "PONG", false in other case.

pingAll

public boolean pingAll()

Description copied from interface: BaseRedisNodes

Ping all Redis nodes. Default timeout per Redis node is 1000 milliseconds

Specified by:

pingAll in interface BaseRedisNodes

Returns:

true if all nodes replied "PONG", false in other case.