Package at.ac.ait.lablink.clients.redisclient

Class RedisClient

java.lang.Object

at.ac.ait.lablink.clients.redisclient.RedisClient

public class RedisClient
extends Object

Class RedisClient.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	RedisClient.RedisActuator	Class RedisActuator.
(package private) class	RedisClient.RedisClientNotifier	Class RedisClientNotifier.
private static class	RedisClient.RedisReader
(package private) class	RedisClient.RedisSensor	Class RedisSensor.
private class	RedisClient.SensorConf

Field Summary

Fields

Modifier and Type	Field	Description
private at.ac.ait.lablink.core.client.impl.LlClient	client
private String	clientDesc
private String	clientName
private boolean	giveShell
private String	groupName
private boolean	isPseudo
private static redis.clients.jedis.JedisPool	jedisPool
private String	llprop
private String	llsync
private static org.apache.logging.log4j.Logger	logger	Logger.
private String	scenarioName
private List<RedisClient.SensorConf>	sensorList

Constructor Summary

Constructors

Constructor	Description
RedisClient()
RedisClient(String redisIpAddress, int redisPort, String scenarioName, String groupName, String clientName, String clientDesc, String llprop, String llsync)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	addRedisKeyAsActuator(String key)	Add Redis key as actuator.
void	addRedisKeyAsSensor(String key, int msTimeInterval)	Add Redis key as sensor.
void	start()	Start the client.

Methods inherited from class java.lang.Object

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

Field Details

logger

private static final org.apache.logging.log4j.Logger logger

Logger.

jedisPool

private static redis.clients.jedis.JedisPool jedisPool

scenarioName

private String scenarioName

groupName

private String groupName

clientName

private String clientName

clientDesc

private String clientDesc

llprop

private String llprop

llsync

private String llsync

giveShell

private boolean giveShell

isPseudo

private boolean isPseudo

sensorList

private List<RedisClient.SensorConf> sensorList

client

private at.ac.ait.lablink.core.client.impl.LlClient client

Constructor Details

RedisClient

public RedisClient()

RedisClient

public RedisClient(String redisIpAddress, int redisPort, String scenarioName, String groupName, String clientName, String clientDesc, String llprop, String llsync) throws at.ac.ait.lablink.core.client.ex.ClientNotReadyException, at.ac.ait.lablink.core.client.ex.CommInterfaceNotSupportedException, at.ac.ait.lablink.core.client.ex.DataTypeNotSupportedException, at.ac.ait.lablink.core.client.ex.NoServicesInClientLogicException, at.ac.ait.lablink.core.client.ex.NoSuchCommInterfaceException, at.ac.ait.lablink.core.client.ex.ServiceIsNotRegisteredWithClientException, at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType, org.apache.commons.configuration.ConfigurationException

Constructor.

Parameters:

redisIpAddress - Redis IP address

redisPort - Redis port

scenarioName - scenario name

groupName - group name

clientName - client name

clientDesc - client description

llprop - Lablink properties

llsync - Lablink sync properties

Throws:

at.ac.ait.lablink.core.client.ex.ClientNotReadyException - client not ready

at.ac.ait.lablink.core.client.ex.CommInterfaceNotSupportedException - comm interface not supported

at.ac.ait.lablink.core.client.ex.DataTypeNotSupportedException - data type not supported

at.ac.ait.lablink.core.client.ex.NoServicesInClientLogicException - no services in client logic

at.ac.ait.lablink.core.client.ex.NoSuchCommInterfaceException - no such comm interface

at.ac.ait.lablink.core.client.ex.ServiceIsNotRegisteredWithClientException - service is not registered with client

at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType - service type does not match client type

org.apache.commons.configuration.ConfigurationException - configuration error

Method Details

addRedisKeyAsSensor

public void addRedisKeyAsSensor(String key, int msTimeInterval) throws at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType

Add Redis key as sensor.

Parameters:

key - Redis key

msTimeInterval - time interval in ms

Throws:

at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType - service type does not match client type exception

addRedisKeyAsActuator

public void addRedisKeyAsActuator(String key) throws at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType

Add Redis key as actuator.

Parameters:

key - Redis key

Throws:

at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType - service type does not match client type exception

start

public void start() throws at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType, at.ac.ait.lablink.core.client.ex.ClientNotReadyException, at.ac.ait.lablink.core.client.ex.NoSuchCommInterfaceException, org.apache.commons.configuration.ConfigurationException, at.ac.ait.lablink.core.client.ex.NoServicesInClientLogicException, at.ac.ait.lablink.core.client.ex.DataTypeNotSupportedException

Start the client.

Throws:

at.ac.ait.lablink.core.client.ex.ServiceTypeDoesNotMatchClientType - service type does not match client type exception

at.ac.ait.lablink.core.client.ex.ClientNotReadyException - client not ready exception

at.ac.ait.lablink.core.client.ex.NoSuchCommInterfaceException - no such comm interface exception

org.apache.commons.configuration.ConfigurationException - configuration exception

at.ac.ait.lablink.core.client.ex.NoServicesInClientLogicException - no services in client logic exception

at.ac.ait.lablink.core.client.ex.DataTypeNotSupportedException - data type not supported exception