org.rifidi.edge.adapter.thingmagic

Class ThingmagicReaderSession

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

org.rifidi.edge.adapter.thingmagic.ThingmagicReaderSession

public class ThingmagicReaderSession
extends AbstractPollIPSensorSession

Author:

Matthew Dean

Constructor Summary

Constructors

Constructor and Description
ThingmagicReaderSession(AbstractSensor<?> sensor, java.lang.String id, java.lang.String host, int port, int reconnectionInterval, int maxConAttempts, NotifierService notifierService, java.lang.String readerID, java.util.Set<AbstractCommandConfiguration<?>> commands) Constructor

Method Summary

Modifier and Type	Method and Description
MessageParsingStrategyFactory	getMessageParsingStrategyFactory() Get a factory for MessageParsingStrategy objects
void	killComand(java.lang.Integer id) This method deletes a command from the session, including the DTO.
boolean	onConnect() Called after the initial socket connection got established.
void	sendMessage(ByteMessage message) Send a message over the line.
java.lang.Integer	submit(java.lang.String commandID, long interval, java.util.concurrent.TimeUnit unit) Submit a command to a reader session for execution.

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

getMessageProcessingStrategyFactory, isMessageAvailable, receiveMessage, receiveMessage

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, 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

ThingmagicReaderSession

public ThingmagicReaderSession(AbstractSensor<?> sensor,
                               java.lang.String id,
                               java.lang.String host,
                               int port,
                               int reconnectionInterval,
                               int maxConAttempts,
                               NotifierService notifierService,
                               java.lang.String readerID,
                               java.util.Set<AbstractCommandConfiguration<?>> commands)

Constructor

Parameters:

sensor -

id - The FACTORY_ID of the session

host - The IP to connect to

port - The port to connect to

reconnectionInterval - The wait time between reconnect attempts

maxConAttempts - The maximum number of times to try to connect

destination - The JMS destination for tags

template - The JSM template for tags

notifierService - The service for sending client notifications

readerID - The FACTORY_ID of the reader that created this session

commands - A thread safe set containing all available commands

Method Detail

getMessageParsingStrategyFactory

public MessageParsingStrategyFactory getMessageParsingStrategyFactory()

Description copied from class: AbstractIPSensorSession

Get a factory for MessageParsingStrategy objects

Returns:

onConnect

public boolean onConnect()
                  throws java.io.IOException

Description copied from class: AbstractIPSensorSession

Called after the initial socket connection got established. Implementations can use this method to send login credentials or receive a welcome message.

Returns:

true if the connect was successful

Throws:

java.io.IOException - if a connection problem occurs

submit

public java.lang.Integer submit(java.lang.String commandID,
                                long interval,
                                java.util.concurrent.TimeUnit unit)

Description copied from class: SensorSession

Submit a command to a reader session for execution. If interval > 0, the command will be scheduled for repeated execution.

Overrides:

submit in class AbstractSensorSession

Parameters:

commandID - The command to execute

interval - The interval between executions

unit - The Unit of time to measure the interval

Returns:

The ID of the job

killComand

public void killComand(java.lang.Integer id)

Description copied from class: SensorSession

This method deletes a command from the session, including the DTO. If the command is recurring, it will unschedule it. This command will not execute the next time the session starts up

Overrides:

killComand in class AbstractSensorSession

Parameters:

id - The ID of the command to kill

sendMessage

public void sendMessage(ByteMessage message)
                 throws java.io.IOException

Description copied from class: AbstractIPSensorSession

Send a message over the line. This method is protected so that subclasses can choose whether or not to expose it to clients.

Throws:

java.io.IOException