Package | Description |
---|---|
io.openmessaging.interceptor |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerInterceptor.postReceive(Message message,
Context attributes)
Invoked after the invocation of
MessageListener.onReceived(Message, MessageListener.Context) . |
void |
ProducerInterceptor.postSend(Message message,
Context attributes)
Invoked immediately after the successful send invocation.
|
void |
ConsumerInterceptor.preReceive(Message message,
Context attributes)
Invoked before the invocation of
MessageListener.onReceived(Message, MessageListener.Context) . |
void |
ProducerInterceptor.preSend(Message message,
Context attributes)
Invoked before the message is actually sent to the network.
|
Copyright © 2017–2020 OpenMessaging. All rights reserved.