org.rifidi.edge.sensors.sessions

Class AbstractPollIPSensorSession

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.AbstractPollIPSensorSession

Direct Known Subclasses:

Alien9800ReaderSession, ThingmagicReaderSession

public abstract class AbstractPollIPSensorSession
extends AbstractIPSensorSession

An implementation of IPSensorSession that uses polling semantics.

Author:

Kyle Neumeier - kyle@pramari.com

Constructor Summary

Constructors

Constructor and Description
AbstractPollIPSensorSession(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
MessageProcessingStrategyFactory	getMessageProcessingStrategyFactory() Get a Factory for MessageProcessingStrategy objects.
boolean	isMessageAvailable() Check if a new message is available.
ByteMessage	receiveMessage() Receive a message.
ByteMessage	receiveMessage(long timeout) Receive a message.

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

AbstractPollIPSensorSession

public AbstractPollIPSensorSession(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

getMessageProcessingStrategyFactory

public MessageProcessingStrategyFactory getMessageProcessingStrategyFactory()

Description copied from class: AbstractIPSensorSession

Get a Factory for MessageProcessingStrategy objects.

Returns:

isMessageAvailable

public boolean isMessageAvailable()
                           throws java.io.IOException

Check if a new message is available.

Returns:

Throws:

java.io.IOException

receiveMessage

public ByteMessage receiveMessage()
                           throws java.io.IOException,
                                  java.util.concurrent.TimeoutException

Receive a message. This method blocks for the amount of time determined by the org.rifidi.edge.sessions.timeout variable.

Returns:

Throws:

java.io.IOException

if - the timeout has expired while waiting.

java.util.concurrent.TimeoutException

receiveMessage

public ByteMessage receiveMessage(long timeout)
                           throws java.io.IOException,
                                  java.util.concurrent.TimeoutException

Receive a message. This method blocks until the message is received or until the given amount of time has expired.

Parameters:

timeout - the time to wait for a response in milliseconds

Returns:

The next message from the reader

Throws:

java.io.IOException

java.util.concurrent.TimeoutException - if the timeout has expired while waiting.