org.rifidi.edge.sensors

Class SensorManagementServiceImpl

java.lang.Object

org.rifidi.edge.sensors.SensorManagementServiceImpl

All Implemented Interfaces:

SensorManagementService

public class SensorManagementServiceImpl
extends java.lang.Object
implements SensorManagementService

Thread asfe implementation of the SensorManagementService

Author:

Jochen Mader - jochen@pramari.com

Constructor Summary

Constructors

Constructor and Description
SensorManagementServiceImpl() Constructor.

Method Summary

Modifier and Type	Method and Description
void	addChild(java.lang.String sensorName, java.lang.String childName) Add a new child to a sensor.
void	addChildren(java.lang.String sensorName, java.util.Collection<java.lang.String> childNames) Add several sensors as children to the sensor.
void	bindReader(AbstractSensor<?> reader, java.util.Dictionary<java.lang.String,java.lang.String> parameters) Used by spring to bind a new AbstractSensor to this service.
void	createSensor(java.lang.String sensorName) Create a new sensor.
void	createSensor(java.lang.String sensorName, java.util.Collection<java.lang.String> childSensors) Create a new sensor that is already hooked up to other sensors.
void	destroySensor(java.lang.String sensorName) Destroy a sensor.
SensorDTO	getDTO(java.lang.String sensorName) Get a serializable representation of the given sensor.
java.util.Set<java.lang.String>	getSensors() Get the names of all registered sensors.
void	publishToEsper(java.lang.String sensorName) Publish all reads from a sensor to esper.
void	removeChild(java.lang.String sensorName, java.lang.String childName) Remove one child from a sensor.
void	removeChildren(java.lang.String sensorName, java.util.Collection<java.lang.String> childrenNames) Remove a number of childrens from a sensor.
void	renameSensor(java.lang.String oldName, java.lang.String newName) Change the name of a sensor.
void	setChildren(java.lang.String sensorName, java.util.Collection<java.lang.String> childNames) Set the sensor's child sensors.
void	setEsperManager(EsperManagementService esperManager)
void	setReader(java.util.Set<AbstractSensor<?>> readers) Used by spring to give the initial list of readers
Sensor	subscribe(java.lang.Object subscriber, java.lang.String sensorName) Subscribe an object to a sensor.
void	unbindReader(AbstractSensor<?> reader, java.util.Dictionary<java.lang.String,java.lang.String> parameters) Used by spring to unbind a disappearing AbstractSensor service from this service.
void	unpublishFromEsper(java.lang.String sensorName) Dont publish the reads from a given sensor.
void	unsubscribe(java.lang.Object subscriber, java.lang.String sensorName) Unsubscribe an object from a sensor.

Methods inherited from class java.lang.Object

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

Constructor Detail

SensorManagementServiceImpl

public SensorManagementServiceImpl()

Constructor.

Method Detail

createSensor

public void createSensor(java.lang.String sensorName,
                         java.util.Collection<java.lang.String> childSensors)
                  throws DuplicateSensorNameException,
                         NoSuchSensorException

Description copied from interface: SensorManagementService

Create a new sensor that is already hooked up to other sensors.

Specified by:

createSensor in interface SensorManagementService

Throws:

DuplicateSensorNameException

NoSuchSensorException

destroySensor

public void destroySensor(java.lang.String sensorName)
                   throws NoSuchSensorException,
                          ImmutableException,
                          InUseException

Description copied from interface: SensorManagementService

Destroy a sensor.

Specified by:

destroySensor in interface SensorManagementService

Throws:

NoSuchSensorException

ImmutableException

InUseException

createSensor

public void createSensor(java.lang.String sensorName)
                  throws DuplicateSensorNameException

Description copied from interface: SensorManagementService

Create a new sensor.

Specified by:

createSensor in interface SensorManagementService

Throws:

DuplicateSensorNameException

subscribe

public Sensor subscribe(java.lang.Object subscriber,
                        java.lang.String sensorName)
                 throws NoSuchSensorException,
                        DuplicateSubscriptionException

Description copied from interface: SensorManagementService

Subscribe an object to a sensor.

Specified by:

subscribe in interface SensorManagementService

Returns:

Throws:

NoSuchSensorException

DuplicateSubscriptionException

unsubscribe

public void unsubscribe(java.lang.Object subscriber,
                        java.lang.String sensorName)
                 throws NoSuchSensorException,
                        NotSubscribedException

Description copied from interface: SensorManagementService

Unsubscribe an object from a sensor.

Specified by:

unsubscribe in interface SensorManagementService

Throws:

NoSuchSensorException

NotSubscribedException

renameSensor

public void renameSensor(java.lang.String oldName,
                         java.lang.String newName)
                  throws NoSuchSensorException,
                         ImmutableException,
                         InUseException

Description copied from interface: SensorManagementService

Change the name of a sensor.

Specified by:

renameSensor in interface SensorManagementService

Throws:

NoSuchSensorException

ImmutableException

InUseException

addChild

public void addChild(java.lang.String sensorName,
                     java.lang.String childName)
              throws ImmutableException,
                     InUseException,
                     NoSuchSensorException

Description copied from interface: SensorManagementService

Add a new child to a sensor.

Specified by:

addChild in interface SensorManagementService

Throws:

ImmutableException

InUseException

NoSuchSensorException

addChildren

public void addChildren(java.lang.String sensorName,
                        java.util.Collection<java.lang.String> childNames)
                 throws ImmutableException,
                        InUseException,
                        NoSuchSensorException

Description copied from interface: SensorManagementService

Add several sensors as children to the sensor.

Specified by:

addChildren in interface SensorManagementService

Throws:

ImmutableException

InUseException

NoSuchSensorException

setChildren

public void setChildren(java.lang.String sensorName,
                        java.util.Collection<java.lang.String> childNames)
                 throws ImmutableException,
                        InUseException,
                        NoSuchSensorException

Description copied from interface: SensorManagementService

Set the sensor's child sensors.

Specified by:

setChildren in interface SensorManagementService

Throws:

ImmutableException

InUseException

NoSuchSensorException

removeChild

public void removeChild(java.lang.String sensorName,
                        java.lang.String childName)
                 throws ImmutableException,
                        InUseException,
                        NoSuchSensorException

Description copied from interface: SensorManagementService

Remove one child from a sensor.

Specified by:

removeChild in interface SensorManagementService

Throws:

ImmutableException

InUseException

NoSuchSensorException

removeChildren

public void removeChildren(java.lang.String sensorName,
                           java.util.Collection<java.lang.String> childrenNames)
                    throws ImmutableException,
                           InUseException,
                           NoSuchSensorException

Description copied from interface: SensorManagementService

Remove a number of childrens from a sensor.

Specified by:

removeChildren in interface SensorManagementService

Throws:

ImmutableException

InUseException

NoSuchSensorException

getSensors

public java.util.Set<java.lang.String> getSensors()

Description copied from interface: SensorManagementService

Get the names of all registered sensors.

Specified by:

getSensors in interface SensorManagementService

Returns:

bindReader

public void bindReader(AbstractSensor<?> reader,
                       java.util.Dictionary<java.lang.String,java.lang.String> parameters)

Used by spring to bind a new AbstractSensor to this service.

Parameters:

reader - the configuration to bind

parameters -

unbindReader

public void unbindReader(AbstractSensor<?> reader,
                         java.util.Dictionary<java.lang.String,java.lang.String> parameters)

Used by spring to unbind a disappearing AbstractSensor service from this service.

Parameters:

reader - the AbstractSensor to unbind

parameters -

setReader

public void setReader(java.util.Set<AbstractSensor<?>> readers)

Used by spring to give the initial list of readers

Parameters:

readers - the initial list of available readers

publishToEsper

public void publishToEsper(java.lang.String sensorName)
                    throws NoSuchSensorException

Description copied from interface: SensorManagementService

Publish all reads from a sensor to esper.

Specified by:

publishToEsper in interface SensorManagementService

Throws:

NoSuchSensorException

unpublishFromEsper

public void unpublishFromEsper(java.lang.String sensorName)
                        throws NoSuchSensorException

Description copied from interface: SensorManagementService

Dont publish the reads from a given sensor.

Specified by:

unpublishFromEsper in interface SensorManagementService

Throws:

NoSuchSensorException

getDTO

public SensorDTO getDTO(java.lang.String sensorName)
                 throws NoSuchSensorException

Description copied from interface: SensorManagementService

Get a serializable representation of the given sensor.

Specified by:

getDTO in interface SensorManagementService

Returns:

Throws:

NoSuchSensorException

setEsperManager

public void setEsperManager(EsperManagementService esperManager)

Parameters:

esperManager - the esperManager to set