org.rifidi.edge.sensors

Class SensorImpl

java.lang.Object

org.rifidi.edge.sensors.SensorImpl

All Implemented Interfaces:

CompositeSensor, CompositeSensorUpdate, Sensor, SensorUpdate

public class SensorImpl
extends java.lang.Object
implements SensorUpdate, CompositeSensorUpdate

Author:

Jochen Mader - jochen@pramari.com

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Map<java.lang.Object,java.util.concurrent.LinkedBlockingQueue<ReadCycle>>	tagSubscriberToQueueMap Map with the subscriber as key and it's queue as value.

Constructor Summary

Constructors

Constructor and Description
SensorImpl(java.lang.String name, java.util.Collection<SensorUpdate> childNodes, java.lang.Boolean immutable)

Method Summary

Modifier and Type	Method and Description
void	addChild(SensorUpdate child) Add a new child sensor.
void	addReceiver(Sensor receiver) Add a sensor to the list of sensors that receive sensor reads from this sensor.
java.util.Set<java.lang.String>	getChildren() Get the names of child sensors this sensor has.
java.lang.String	getName() Get the name of the sensor.
java.lang.Boolean	isImmutable() Check if the sensor is immutable.
java.lang.Boolean	isInUse() Check if the sensor is in use.
EsperEventContainer	receive(java.lang.Object object) Objects subscribed to the sensor use this method to acquire the read results.
void	removeChild(SensorUpdate child) Remove a child sensor.
void	removeChildren(java.util.Collection<SensorUpdate> children) Remove several child sensors.
void	removeReceiver(Sensor receiver) Remove a sensor from the list of sensors that receive sensor reads from this sensor.
void	send(ReadCycle cycle) Send sensor results to this sensor.
void	sendEvent(java.lang.Object event) Send a non ReadCycle event to esper.
void	setName(java.lang.String name)
void	subscribe(java.lang.Object object) Subscribe an object to the sensor.
void	unsubscribe(java.lang.Object object) Unsubscribe an object from the sensor.

Methods inherited from class java.lang.Object

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

Field Detail

tagSubscriberToQueueMap

public final java.util.Map<java.lang.Object,java.util.concurrent.LinkedBlockingQueue<ReadCycle>> tagSubscriberToQueueMap

Map with the subscriber as key and it's queue as value.

Constructor Detail

SensorImpl

public SensorImpl(java.lang.String name,
                  java.util.Collection<SensorUpdate> childNodes,
                  java.lang.Boolean immutable)

Parameters:

name -

childNodes -

immutable -

Method Detail

getName

public java.lang.String getName()

Description copied from interface: Sensor

Get the name of the sensor.

Specified by:

getName in interface Sensor

Returns:

setName

public void setName(java.lang.String name)
             throws ImmutableException,
                    InUseException

Specified by:

setName in interface SensorUpdate

Throws:

ImmutableException

InUseException

getChildren

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

Description copied from interface: CompositeSensor

Get the names of child sensors this sensor has.

Specified by:

getChildren in interface CompositeSensor

Returns:

addChild

public void addChild(SensorUpdate child)
              throws ImmutableException,
                     InUseException

Description copied from interface: CompositeSensorUpdate

Add a new child sensor.

Specified by:

addChild in interface CompositeSensorUpdate

Throws:

ImmutableException

InUseException

removeChild

public void removeChild(SensorUpdate child)
                 throws ImmutableException,
                        InUseException

Description copied from interface: CompositeSensorUpdate

Remove a child sensor.

Specified by:

removeChild in interface CompositeSensorUpdate

Throws:

ImmutableException

InUseException

removeChildren

public void removeChildren(java.util.Collection<SensorUpdate> children)
                    throws ImmutableException,
                           InUseException

Description copied from interface: CompositeSensorUpdate

Remove several child sensors.

Specified by:

removeChildren in interface CompositeSensorUpdate

Throws:

ImmutableException

InUseException

subscribe

public void subscribe(java.lang.Object object)
               throws DuplicateSubscriptionException

Description copied from interface: SensorUpdate

Subscribe an object to the sensor.

Specified by:

subscribe in interface SensorUpdate

Throws:

DuplicateSubscriptionException

unsubscribe

public void unsubscribe(java.lang.Object object)
                 throws NotSubscribedException

Description copied from interface: SensorUpdate

Unsubscribe an object from the sensor.

Specified by:

unsubscribe in interface SensorUpdate

Throws:

NotSubscribedException

addReceiver

public void addReceiver(Sensor receiver)

Description copied from interface: SensorUpdate

Add a sensor to the list of sensors that receive sensor reads from this sensor.

Specified by:

addReceiver in interface SensorUpdate

removeReceiver

public void removeReceiver(Sensor receiver)

Description copied from interface: SensorUpdate

Remove a sensor from the list of sensors that receive sensor reads from this sensor.

Specified by:

removeReceiver in interface SensorUpdate

isImmutable

public java.lang.Boolean isImmutable()

Description copied from interface: Sensor

Check if the sensor is immutable.

Specified by:

isImmutable in interface Sensor

Returns:

isInUse

public java.lang.Boolean isInUse()

Description copied from interface: Sensor

Check if the sensor is in use.

Specified by:

isInUse in interface Sensor

Returns:

send

public void send(ReadCycle cycle)

Description copied from interface: Sensor

Send sensor results to this sensor.

Specified by:

send in interface Sensor

sendEvent

public void sendEvent(java.lang.Object event)

Description copied from interface: Sensor

Send a non ReadCycle event to esper.

Specified by:

sendEvent in interface Sensor

receive

public EsperEventContainer receive(java.lang.Object object)
                            throws NotSubscribedException

Description copied from interface: Sensor

Objects subscribed to the sensor use this method to acquire the read results.

Specified by:

receive in interface Sensor

Throws:

NotSubscribedException