io.openmessaging.consumer

Interface MessageListener.Context

Enclosing interface:

MessageListener

public static interface MessageListener.Context

Method Summary

Modifier and Type	Method and Description
void	ack() Acknowledges the specified and consumed message, which is related to this MessageContext.
KeyValue	attributes() Returns the attributes of this MessageContext instance.

Method Detail

attributes

KeyValue attributes()

Returns the attributes of this MessageContext instance.

Returns:

the attributes

ack

void ack()

Acknowledges the specified and consumed message, which is related to this MessageContext.

Messages that have been received but not acknowledged may be redelivered.

Throws:

OMSRuntimeException - if the consumer fails to acknowledge the messages due to some internal error.