| Package | Description |
|---|---|
| io.openmessaging | |
| io.openmessaging.consumer |
| Class and Description |
|---|
| 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}. |
| Class and 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. |
| 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.