Package | Description |
---|---|
io.openmessaging | |
io.openmessaging.consumer | |
io.openmessaging.extension | |
io.openmessaging.message |
Modifier and Type | Method and Description |
---|---|
Optional<Extension> |
Client.getExtension()
Get the extension method, and this interface is optional, Therefore, users need to check whether this interface
has been implemented by vendors.
|
Modifier and Type | Method and Description |
---|---|
List<Message> |
PullConsumer.batchReceive(String queueName,
QueueMetaData queueMetaData,
MessageReceipt messageReceipt,
long timeout)
Receive message in asynchronous way.
|
Message |
PullConsumer.receive(String queueName,
QueueMetaData queueMetaData,
MessageReceipt messageReceipt,
long timeout)
Receives the next message from the which bind queue,partition and receiptId of this consumer in pull model.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Extension
This interface contains some methods are used for getting configurations related implementation.
|
interface |
ExtensionHeader
The
ExtensionHeader interface contains extended properties for common implementations in current messaging
and streaming field, such as the queue-based partitioning implementation, but the related properties in this
interface are not mandatory. |
interface |
QueueMetaData
This interface
QueueMetaData contains methods are used for getting configurations related some certain
implementation. |
Modifier and Type | Method and Description |
---|---|
ExtensionHeader |
Message.extensionHeader()
This interface is optional, Therefore, users need to check whether the interface is implemented and the
correctness of its implementation.
|
Copyright © 2017–2020 OpenMessaging. All rights reserved.