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, Context attributes) Invoked after the invocation of MessageListener.onReceived(Message, MessageListener.Context).
void	preReceive(Message message, Context attributes) Invoked before the invocation of MessageListener.onReceived(Message, MessageListener.Context).

Method Detail

preReceive

void preReceive(Message message,
                Context 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,
                 Context 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.