org.rifidi.edge.adapter.generic

Class GenericSensorSession

java.lang.Object

org.rifidi.edge.sensors.SensorSession

org.rifidi.edge.sensors.sessions.AbstractSensorSession

org.rifidi.edge.sensors.sessions.AbstractServerSocketSensorSession

org.rifidi.edge.adapter.generic.GenericSensorSession

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback

public class GenericSensorSession
extends AbstractServerSocketSensorSession
implements org.eclipse.paho.client.mqttv3.MqttCallback

The session class for the Generic sensor.

Author:

Matthew Dean - matt@pramari.com

Constructor Summary

Constructors

Constructor and Description
GenericSensorSession(AbstractSensor<?> sensor, java.lang.String ID, NotifierService notifierService, java.lang.String readerID, int serverSocketPort, java.lang.Boolean restdebug, java.util.Set<AbstractCommandConfiguration<?>> commandConfigurations)

Method Summary

Modifier and Type	Method and Description
void	connectionLost(java.lang.Throwable arg0)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken arg0)
void	messageArrived(java.lang.String arg0, org.eclipse.paho.client.mqttv3.MqttMessage arg1)
java.util.Set<TagReadEvent>	processTags(java.lang.String json)
void	sendTag(byte[] message) Parses and sends the tag to the desired destination.
void	sendTags(java.util.Set<TagReadEvent> tres) Parses and sends the tag to the desired destination.

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

disconnect, killComand, restoreCommands, submit, submit, toString

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

getCommandInstance, getStatus, submit, submitAndBlock, suspendCommand

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericSensorSession

public GenericSensorSession(AbstractSensor<?> sensor,
                            java.lang.String ID,
                            NotifierService notifierService,
                            java.lang.String readerID,
                            int serverSocketPort,
                            java.lang.Boolean restdebug,
                            java.util.Set<AbstractCommandConfiguration<?>> commandConfigurations)

Method Detail

sendTag

public void sendTag(byte[] message)

Parses and sends the tag to the desired destination.

Parameters:

tag -

sendTags

public void sendTags(java.util.Set<TagReadEvent> tres)

Parses and sends the tag to the desired destination.

Parameters:

tag -

connectionLost

public void connectionLost(java.lang.Throwable arg0)

Specified by:

connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken arg0)

Specified by:

deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback

messageArrived

public void messageArrived(java.lang.String arg0,
                           org.eclipse.paho.client.mqttv3.MqttMessage arg1)
                    throws java.lang.Exception

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback

Throws:

java.lang.Exception

processTags

public java.util.Set<TagReadEvent> processTags(java.lang.String json)
                                        throws java.io.IOException

Throws:

java.io.IOException