io.openmessaging.interceptor

Interface ConsumerInterceptor

public interface ConsumerInterceptor

A ConsumerInterceptor is used to intercept consume operations of push consumer.

Since:

OMS 1.0.0

Version:

OMS 1.0.0

Method Summary

Modifier and Type	Method and Description
void	postReceive(Message message, KeyValue attributes) Invoked after the invocation of MessageListener.onReceived(Message, MessageListener.Context).
void	preReceive(Message message, KeyValue attributes) Invoked before the invocation of MessageListener.onReceived(Message, MessageListener.Context).

Method Detail

preReceive

void preReceive(Message message,
                KeyValue attributes)

Invoked before the invocation of MessageListener.onReceived(Message, MessageListener.Context).

Parameters:

message - the message is actually received

attributes - the extensible attributes delivered to the intercept thread

postReceive

void postReceive(Message message,
                 KeyValue attributes)

Invoked after the invocation of MessageListener.onReceived(Message, MessageListener.Context).

Parameters:

message - the message is actually received

attributes - the extensible attributes delivered to the intercept thread