org.rifidi.edge.sensors.sessions

Class AbstractIPSensorSession

java.lang.Object

org.rifidi.edge.sensors.SensorSession

org.rifidi.edge.sensors.sessions.AbstractSensorSession

org.rifidi.edge.sensors.sessions.AbstractIPSensorSession

Direct Known Subclasses:

AbstractPollIPSensorSession, AbstractPubSubIPSensorSession

public abstract class AbstractIPSensorSession
extends AbstractSensorSession

Base implementation of a ReaderPlugin that uses TCP/IP as a means of communicating with a physical reader. This base class handles socket I/O and threads. Some important features: Handles automatic reconnection using two variables: maxNumReconnectionAttempts and reconnectInterval. If maxNumReconnectAttempts is set to -1, it will try to reconnect forever. reconnectInterval is the time in between two successive reconnection attempts. Provides an onConnect method that is the first thing that is executed when a valid TCP/IP connection has been established. The implementation can, at this point send login credentials or receive a welcome message. The MessageParsingStrategy lets the implementation determine when the bytes form a logical message. The messageProcessingStrategy lets the implementaion determine what to do with the receieved messages

Author:

Jochen Mader - jochen@pramari.com, Kyle Neumeier - kyle@pramari.com

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	disconnect() Close the connection and stop processing of commands.
java.lang.String	getHost() Get the host this session is connected to
int	getPort() Get the port this session is connected to
java.lang.String	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

AbstractIPSensorSession

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

Constructor.

Parameters:

sensor -

host - HostName of the hardware reader

port - Port of the hardware reader

reconnectionInterval - Length of time between reconnects. Specified in MS

maxConAttempts - Maximum number of reconnect attempts to make

commandConfigurations -

Method Detail

getHost

public java.lang.String getHost()

Get the host this session is connected to

Returns:

the host

getPort

public int getPort()

Get the port this session is connected to

Returns:

the port

disconnect

public void disconnect()

Description copied from class: SensorSession

Close the connection and stop processing of commands.

Specified by:

disconnect in class SensorSession

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object