| Interface | Description |
|---|---|
| MessageListener |
A message listener must implement this
MessageListener interface and register
itself to a consumer instance to asynchronously receive messages. |
| MessageListener.Context | |
| PullConsumer |
A
PullConsumer pulls messages from the specified queue,
and supports submit the consume result by acknowledgement. |
| PushConsumer |
A
PushConsumer receives messages from multiple queues, these messages are pushed from
MOM server to PushConsumer client. |
| StreamingConsumer |
A
StreamingConsumer provides low level APIs to open multiple streams
from a specified queue and then retrieve messages from them through @{code StreamingIterator}. |
| StreamingIterator |
A
StreamingIterator is provided by Stream and is used to
retrieve messages a specified stream like a read-only iterator. |
Copyright © 2017–2018 OpenMessaging. All rights reserved.