Uses of Interface
io.openmessaging.Message

Packages that use Message

Package	Description
io.openmessaging
io.openmessaging.consumer
io.openmessaging.interceptor
io.openmessaging.producer

Uses of Message in io.openmessaging

Subinterfaces of Message in io.openmessaging

Modifier and Type	Interface and Description
interface	BytesMessage The BytesMessage contains a stream of uninterpreted bytes.

Methods in io.openmessaging that return Message

Modifier and Type	Method and Description
Message	Message.putSysHeaders(String key, double value) Puts a String-double KeyValue entry to the system headers of a Message.
Message	Message.putSysHeaders(String key, int value) Puts a String-int KeyValue entry to the system headers of a Message.
Message	Message.putSysHeaders(String key, long value) Puts a String-long KeyValue entry to the system headers of a Message.
Message	Message.putSysHeaders(String key, String value) Puts a String-String KeyValue entry to the system headers of a Message.
Message	Message.putUserHeaders(String key, double value) Puts a String-double KeyValue entry to the user headers of a Message.
Message	Message.putUserHeaders(String key, int value) Puts a String-int KeyValue entry to the user headers of a Message.
Message	Message.putUserHeaders(String key, long value) Puts a String-long KeyValue entry to the user headers of a Message.
Message	Message.putUserHeaders(String key, String value) Puts a String-String KeyValue entry to the user headers of a Message.

Uses of Message in io.openmessaging.consumer

Methods in io.openmessaging.consumer that return Message

Modifier and Type	Method and Description
Message	StreamingIterator.next() Returns the next message in the iteration and advances the offset position.
Message	StreamingIterator.previous() Returns the previous message in the iteration and moves the offset position backwards.
Message	PullConsumer.receive() Receives the next message from the attached queues of this consumer.
Message	PullConsumer.receive(KeyValue attributes) Receives the next message from the attached queues of this consumer, using the specified attributes.

Methods in io.openmessaging.consumer with parameters of type Message

Modifier and Type	Method and Description
void	MessageListener.onReceived(Message message, MessageListener.Context context) Callback method to receive incoming messages.

Uses of Message in io.openmessaging.interceptor

Methods in io.openmessaging.interceptor with parameters of type Message

Modifier and Type	Method and Description
void	ConsumerInterceptor.postReceive(Message message, KeyValue attributes) Invoked after the invocation of MessageListener.onReceived(Message, MessageListener.Context).
void	ProducerInterceptor.postSend(Message message, KeyValue attributes) Invoked immediately after the successful send invocation.
void	ProducerInterceptor.postSend(Message message, KeyValue attributes, OMSException sendException) Invoked immediately after the failed send invocation.
void	ConsumerInterceptor.preReceive(Message message, KeyValue attributes) Invoked before the invocation of MessageListener.onReceived(Message, MessageListener.Context).
void	ProducerInterceptor.preSend(Message message, KeyValue attributes) Invoked before the message is actually sent to the network.

Uses of Message in io.openmessaging.producer

Methods in io.openmessaging.producer with parameters of type Message

Modifier and Type	Method and Description
void	LocalTransactionExecutor.check(Message message, LocalTransactionExecutor.CheckContext context) Checks the status of the local transaction branch.
void	LocalTransactionExecutor.execute(Message message, LocalTransactionExecutor.ExecutionContext context) Executes the local transaction branch after the message is sent successfully, and submits the status whether the transaction was successfully committed or rolled back.
SendResult	Producer.send(Message message) Sends a message to the specified destination synchronously, the destination should be preset to sysHeaders(), other header fields as well.
BatchMessageSender	BatchMessageSender.send(Message message) Submits a message to this sender
SendResult	Producer.send(Message message, KeyValue attributes) Sends a message to the specified destination synchronously, using the specified attributes, the destination should be preset to sysHeaders(), other header fields as well.
SendResult	Producer.send(Message message, LocalTransactionExecutor branchExecutor, KeyValue attributes) Sends a transactional message to the specified destination synchronously, using the specified attributes, the destination should be preset to sysHeaders(), 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 sysHeaders(), other header fields as well.
Future<SendResult>	Producer.sendAsync(Message message, KeyValue attributes) Sends a message to the specified destination asynchronously, using the specified attributes, the destination should be preset to sysHeaders(), other header fields as well.
void	Producer.sendOneway(Message message) Sends a message to the specified destination in one way, the destination should be preset to Message.BuiltinKeys, other header fields as well.
void	Producer.sendOneway(Message message, KeyValue properties) Sends a message to the specified destination in one way, using the specified attributes, the destination should be preset to Message.BuiltinKeys, other header fields as well.