Interface | Description |
---|---|
RecurringTaskFactory<T extends ExecutionContext> |
Used for generating recurring tasks by a ConnectionBuilder.
|
Class | Description |
---|---|
ErrorTask<T extends ExecutionContext> |
Checks for errors, and raises a flag if necessary.
|
ExecutionTask<T extends ExecutionContext> |
Executes ExecutableMessage objects which have been read.
|
MessageQueue<T extends ExecutionContext> |
Queues incoming and outgoing messages in a thread-safe manner.
|
ReadTask<T extends ExecutionContext> |
Reads incoming messages and stores them in a MessageQueue.
|
RecurringTask<T extends ExecutionContext> |
Represents a task with access to an ExecutionContext that should be repeated at a given interval until it is
cancelled.
|
WriteTask<T extends ExecutionContext> |
Writes messages from the outgoing list in the MessageQueue.
|