io.openmessaging.interceptor

Interface ProducerInterceptor

public interface ProducerInterceptor

A ProducerInterceptor is used to intercept send operations of producer.

The interceptor is able to view or modify the message being transmitted and collect the send record.

Since:

OMS 1.0.0

Version:

OMS 1.0.0

Method Summary

Modifier and Type	Method and Description
void	postSend(Message message, Context attributes) Invoked immediately after the successful send invocation.
void	preSend(Message message, Context attributes) Invoked before the message is actually sent to the network.

Method Detail

preSend

void preSend(Message message,
             Context attributes)

Invoked before the message is actually sent to the network.

This allows for modification of the message if necessary.

Parameters:

message - a message will be sent.

attributes - the extensible attributes delivered to the intercept thread.

postSend

void postSend(Message message,
              Context attributes)

Invoked immediately after the successful send invocation.

Parameters:

message - the message is actually sent.

attributes - the extensible attributes delivered to the intercept thread.