| Class | Description |
|---|---|
| CountedScheduleSink<T> |
DequeueTask consumer to convert raw Artemis metadata into a
CountedSchedule and forward it, along with the received data
T to a target message sink. |
| CountedScheduleTask<T> |
Enqueues a message that will only be delivered to consumers at a specified
time in the future and makes a sender-specified delivery count available in
the metadata.
|
| DequeueTask<T> |
Receives messages asynchronously from a queue and dispatches them to a
consumer.
|
| EnqueueTask<T> |
Puts messages on a queue, asynchronously.
|
| MessageBodyReader<T> |
Reads the body of a message from the underlying Artemis buffer.
|
| MessageBodyWriter<T> |
Writes the body of a message to the underlying Artemis buffer.
|
| Messages | |
| QChannelFactory<T> | |
| QueueConnector |
Provides access to an Artemis queue.
|
| ScheduleTask<T> |
Enqueues a message that will only be delivered to consumers at a specified
time in the future.
|
| ServerConnector |
Establishes a connection and client session with the Artemis server.
|