org.springframework.data.redis.connection.jedis

Class JedisSentinelConnection

java.lang.Object

org.springframework.data.redis.connection.jedis.JedisSentinelConnection

All Implemented Interfaces:

Closeable, AutoCloseable, RedisSentinelCommands, RedisSentinelConnection

public class JedisSentinelConnection
extends Object
implements RedisSentinelConnection

Since:

1.4

Author:

Christoph Strobl

Constructor Summary

Constructors

Constructor and Description
JedisSentinelConnection(redis.clients.jedis.Jedis jedis)
JedisSentinelConnection(RedisNode sentinel)
JedisSentinelConnection(String host, int port)

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	doInit(redis.clients.jedis.Jedis jedis) Do what ever is required to establish the connection to redis.
void	failover(NamedNode master) Force a failover as if the master was not reachable.
boolean	isOpen()
List<RedisServer>	masters() Get a Collection of monitored masters and their state.
void	monitor(RedisServer server) Tell sentinel to start monitoring a new master with the specified RedisNode.getName(), RedisNode.getHost(), RedisNode.getPort(), and RedisServer.getQuorum().
void	remove(NamedNode master) Removes given master.
void	remove(String masterName)
List<RedisServer>	slaves(NamedNode master) Show list of slaves for given master.
List<RedisServer>	slaves(String masterName)

Methods inherited from class java.lang.Object

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

Constructor Detail

JedisSentinelConnection

public JedisSentinelConnection(RedisNode sentinel)

JedisSentinelConnection

public JedisSentinelConnection(String host,
                               int port)

JedisSentinelConnection

public JedisSentinelConnection(redis.clients.jedis.Jedis jedis)

Method Detail

failover

public void failover(NamedNode master)

Description copied from interface: RedisSentinelCommands

Force a failover as if the master was not reachable.

Specified by:

failover in interface RedisSentinelCommands

Parameters:

master - must not be null.

masters

public List<RedisServer> masters()

Description copied from interface: RedisSentinelCommands

Get a Collection of monitored masters and their state.

Specified by:

masters in interface RedisSentinelCommands

Returns:

Collection of RedisServers. Never null.

slaves

public List<RedisServer> slaves(NamedNode master)

Description copied from interface: RedisSentinelCommands

Show list of slaves for given master.

Specified by:

slaves in interface RedisSentinelCommands

Parameters:

master - must not be null.

Returns:

Collection of RedisServers. Never null.

slaves

public List<RedisServer> slaves(String masterName)

Parameters:

masterName -

Returns:

See Also:

RedisSentinelCommands.slaves(NamedNode)

remove

public void remove(NamedNode master)

Description copied from interface: RedisSentinelCommands

Removes given master. The server will no longer be monitored and will no longer be returned by RedisSentinelCommands.masters().

Specified by:

remove in interface RedisSentinelCommands

Parameters:

master - must not be null.

remove

public void remove(String masterName)

Parameters:

masterName -

See Also:

RedisSentinelCommands.remove(NamedNode)

monitor

public void monitor(RedisServer server)

Description copied from interface: RedisSentinelCommands

Tell sentinel to start monitoring a new master with the specified RedisNode.getName(), RedisNode.getHost(), RedisNode.getPort(), and RedisServer.getQuorum().

Specified by:

monitor in interface RedisSentinelCommands

Parameters:

server - must not be null.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

doInit

protected void doInit(redis.clients.jedis.Jedis jedis)

Do what ever is required to establish the connection to redis.

Parameters:

jedis -

isOpen

public boolean isOpen()

Specified by:

isOpen in interface RedisSentinelConnection

Returns:

true if connected to server