Package io.vertigo.connectors.redis

Class RedisConnector

java.lang.Object

io.vertigo.connectors.redis.RedisConnector

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.Connector<redis.clients.jedis.UnifiedJedis>, io.vertigo.core.node.component.CoreComponent

public class RedisConnector
extends Object
implements io.vertigo.core.node.component.Connector<redis.clients.jedis.UnifiedJedis>, io.vertigo.core.node.component.Activeable

Author:

pchretien, npiedeloup

Field Summary

Fields inherited from interface io.vertigo.core.node.component.Connector

DEFAULT_CONNECTOR_NAME

Constructor Summary

Constructors

Constructor

Description

RedisConnector(io.vertigo.core.resource.ResourceManager resourceManager, Optional<String> connectorNameOpt, Optional<String> redisHost, Optional<Integer> redisPort, Optional<String> masternameOpt, Optional<String> sentinelsOpt, Optional<String> clusterNodesOpt, int redisDatabase, Optional<String> usernameOpt, Optional<String> passwordOpt, boolean ssl, Optional<String> trustStoreUrlOpt, Optional<String> trustStorePasswordOpt, Optional<Integer> maxTotalOpt, Optional<Integer> minIdleOpt)

Constructor.

Method Summary

Modifier and Type	Method	Description
redis.clients.jedis.UnifiedJedis	getClient()
redis.clients.jedis.Jedis	getClient(String key)
String	getName()
boolean	isMultiNodes()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

RedisConnector

@Inject
public RedisConnector(io.vertigo.core.resource.ResourceManager resourceManager,
 Optional<String> connectorNameOpt,
 Optional<String> redisHost,
 Optional<Integer> redisPort,
 Optional<String> masternameOpt,
 Optional<String> sentinelsOpt,
 Optional<String> clusterNodesOpt,
 int redisDatabase,
 Optional<String> usernameOpt,
 Optional<String> passwordOpt,
 boolean ssl,
 Optional<String> trustStoreUrlOpt,
 Optional<String> trustStorePasswordOpt,
 Optional<Integer> maxTotalOpt,
 Optional<Integer> minIdleOpt)

Constructor.

Parameters:

connectorNameOpt - name of the connector (main by default)

redisHost - REDIS server host name

redisPort - REDIS server port

redisDatabase - REDIS database index

passwordOpt - password (optional)

Method Details

getClient

public redis.clients.jedis.UnifiedJedis getClient()

Specified by:

getClient in interface io.vertigo.core.node.component.Connector<redis.clients.jedis.UnifiedJedis>

Returns:

unifiedJedis client (DON't USE try-with-ressource pattern : it close the pool)

getClient

public redis.clients.jedis.Jedis getClient(String key)

Parameters:

key - Key used to find slot, may use Hash-tags of Redis and use partition key between {}. Ex: myPrefix-{myPartioningKey}-myFonctionalKey. Warning : only first {} is used !

Returns:

jedis client for one node (use try-with-resource pattern)

isMultiNodes

public boolean isMultiNodes()

getName

public String getName()

Specified by:

getName in interface io.vertigo.core.node.component.Connector<redis.clients.jedis.UnifiedJedis>

start

public void start()

Specified by:

start in interface io.vertigo.core.node.component.Activeable

stop

public void stop()

Specified by:

stop in interface io.vertigo.core.node.component.Activeable