org.rifidi.edge.sensors.sessions

Class AbstractPubSubIPSensorSession

java.lang.Object

org.rifidi.edge.sensors.SensorSession

org.rifidi.edge.sensors.sessions.AbstractSensorSession

org.rifidi.edge.sensors.sessions.AbstractIPSensorSession

org.rifidi.edge.sensors.sessions.AbstractPubSubIPSensorSession

Direct Known Subclasses:

AwidGPIOSession, AwidSession

public abstract class AbstractPubSubIPSensorSession
extends AbstractIPSensorSession

An implementation of IPSensorSession with Publish-Subscribe semantics. Clients can register themselves with this session and be notified when a new message is available

Author:

Kyle Neumeier - kyle@pramari.com

Constructor Summary

Constructors

Constructor and Description
AbstractPubSubIPSensorSession(AbstractSensor<?> sensor, java.lang.String ID, java.lang.String host, int port, int reconnectionInterval, int maxConAttempts, java.util.Set<AbstractCommandConfiguration<?>> commandConfigurations)

Method Summary

Modifier and Type	Method and Description
void	subscribe(IPSessionEndpoint subscriber) Subscribe to new messages.
void	unsubscribe(IPSessionEndpoint subscriber) Unsubscribe to messages

Methods inherited from class org.rifidi.edge.sensors.sessions.AbstractIPSensorSession

disconnect, getHost, getPort, toString

Methods inherited from class org.rifidi.edge.sensors.sessions.AbstractSensorSession

getCommandInstance, getStatus, killComand, submit, submit, submit, submitAndBlock, suspendCommand

Methods inherited from class org.rifidi.edge.sensors.SensorSession

connect, getCommands, getDTO, getID, getSensor, getTimeout, handleTimeout, killAllCommands, restoreCommands

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPubSubIPSensorSession

public AbstractPubSubIPSensorSession(AbstractSensor<?> sensor,
                                     java.lang.String ID,
                                     java.lang.String host,
                                     int port,
                                     int reconnectionInterval,
                                     int maxConAttempts,
                                     java.util.Set<AbstractCommandConfiguration<?>> commandConfigurations)

Parameters:

sensor -

ID -

host -

port -

reconnectionInterval -

maxConAttempts -

commandConfigurations -

Method Detail

subscribe

public void subscribe(IPSessionEndpoint subscriber)

Subscribe to new messages.

Parameters:

subscriber -

unsubscribe

public void unsubscribe(IPSessionEndpoint subscriber)

Unsubscribe to messages

Parameters:

subscriber -