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, KeyValue attributes) Invoked immediately after the successful send invocation.
void	postSend(Message message, KeyValue attributes, OMSException sendException) Invoked immediately after the failed send invocation.
void	preSend(Message message, KeyValue attributes) Invoked before the message is actually sent to the network.

Method Detail

preSend

void preSend(Message message,
             KeyValue 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,
              KeyValue attributes)

Invoked immediately after the successful send invocation.

Parameters:

message - the message is actually sent

attributes - the extensible attributes delivered to the intercept thread

postSend

void postSend(Message message,
              KeyValue attributes,
              OMSException sendException)

Invoked immediately after the failed send invocation.

Parameters:

message - the message is actually sent

attributes - the extensible attributes delivered to the intercept thread

sendException - the occurred exception in the send invocation