Package | Description |
---|---|
io.openmessaging.consumer | |
io.openmessaging.interceptor | |
io.openmessaging.message | |
io.openmessaging.producer |
Modifier and Type | Method and Description |
---|---|
Message |
PullConsumer.receive()
Receives the next message from the attached queues of this consumer.
|
Message |
PullConsumer.receive(long timeout)
Receives the next message from the bind queues of this consumer in pull model.
|
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 | Method and Description |
---|---|
List<Message> |
PullConsumer.batchReceive(long timeout)
Receive message in asynchronous way.
|
List<Message> |
PullConsumer.batchReceive(String queueName,
QueueMetaData queueMetaData,
MessageReceipt messageReceipt,
long timeout)
Receive message in asynchronous way.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageListener.onReceived(Message message,
MessageListener.Context context)
Callback method to receive incoming messages.
|
Modifier and Type | Method and Description |
---|---|
void |
BatchMessageListener.onReceived(List<Message> batchMessage,
BatchMessageListener.Context context)
Callback method to receive incoming messages.
|
Modifier and Type | Method and Description |
---|---|
void |
ConsumerInterceptor.postReceive(Message message,
Context attributes)
Invoked after the invocation of
MessageListener.onReceived(Message, MessageListener.Context) . |
void |
ProducerInterceptor.postSend(Message message,
Context attributes)
Invoked immediately after the successful send invocation.
|
void |
ConsumerInterceptor.preReceive(Message message,
Context attributes)
Invoked before the invocation of
MessageListener.onReceived(Message, MessageListener.Context) . |
void |
ProducerInterceptor.preSend(Message message,
Context attributes)
Invoked before the message is actually sent to the network.
|
Modifier and Type | Method and Description |
---|---|
Message |
MessageFactory.createMessage(String queueName,
byte[] body)
Creates a
Message object. |
Modifier and Type | Method and Description |
---|---|
void |
TransactionStateCheckListener.check(Message message,
TransactionStateCheckListener.TransactionalContext context)
Checks the status of the local transaction branch.
|
TransactionalResult |
Producer.prepare(Message message)
Sends a transactional message to the specified destination synchronously, the destination should be preset to
header() , other header fields as well. |
SendResult |
Producer.send(Message message)
Sends a message to the specified destination synchronously, the destination should be preset to
header() , other header fields as well. |
Future<SendResult> |
Producer.sendAsync(Message message)
Sends a message to the specified destination asynchronously, the destination should be preset to
header() , other header fields as well. |
void |
Producer.sendOneway(Message message)
There is no
Promise related or RuntimeException thrown. |
Modifier and Type | Method and Description |
---|---|
void |
Producer.send(List<Message> messages)
Send batch messages to server.
|
Future<SendResult> |
Producer.sendAsync(List<Message> messages)
Send messages to the specified destination asynchronously, the destination should be preset to
header() , other header fields as well. |
void |
Producer.sendOneway(List<Message> messages)
There is no
Promise related or RuntimeException thrown. |
Copyright © 2017–2020 OpenMessaging. All rights reserved.