| Interface | Description |
|---|---|
| IPSessionEndpoint |
An interface to implement for objects that wish to be notified when a new
message is available from the IPSensorSession
|
| MessageParsingStrategy |
This interface allows sensor plugins to implement the functionality to
determine what constitutes a logical message from the sensor.
|
| MessageParsingStrategyFactory |
This interface allows sensor plugins to produce new MessageParsingStrategies.
|
| MessageProcessingStrategy |
This interface allows sensor plugins to implement the functionality to
determine what to do with a logical message once it has been read from the
socket
|
| MessageProcessingStrategyFactory |
Allows sensor plugins to create a message parsing strategies
|
| Class | Description |
|---|---|
| AbstractIPSensorSession |
Base implementation of a ReaderPlugin that uses TCP/IP as a means of
communicating with a physical reader.
|
| AbstractPollIPSensorSession |
An implementation of IPSensorSession that uses polling semantics.
|
| AbstractPubSubIPSensorSession |
An implementation of IPSensorSession with Publish-Subscribe semantics.
|
| AbstractSensorSession |
An Abstract class for concrete ReaderSessions to extend.
|
| AbstractServerSocketSensorSession |
When the session is started, it opens up a serversocket and uses the executor
pattern to handle each new request.
|
| PubSubMessageProcessingStrategy |
This is a MessageProcessingStrategy that will notify subscribers when a new
message has arrived
|
| QueueingMessageProcessingStrategy |
An implementation of MessageProcessingStrategy that puts incoming messages on a
queue
|
| ReadThread |
Base class of a runnable used to read from an inputstream.
|
| ServerSocketSensorSessionReadThread |
Override the read thread to ensure that the socket is closed when the thread
is finished executing
|
| WriteThread |
Runnable for writing messages to an outputstream.
|