io.eventuate.tram.consumer.common

Class DuplicateDetectingMessageHandlerDecorator

java.lang.Object

io.eventuate.tram.consumer.common.DuplicateDetectingMessageHandlerDecorator

All Implemented Interfaces:

MessageHandlerDecorator, java.util.function.BiConsumer<SubscriberIdAndMessage,MessageHandlerDecoratorChain>

public class DuplicateDetectingMessageHandlerDecorator
extends java.lang.Object
implements MessageHandlerDecorator

Constructor Summary

Constructors

Constructor and Description
DuplicateDetectingMessageHandlerDecorator(DuplicateMessageDetector duplicateMessageDetector)

Method Summary

Modifier and Type	Method and Description
void	accept(SubscriberIdAndMessage subscriberIdAndMessage, MessageHandlerDecoratorChain messageHandlerDecoratorChain)
int	getOrder()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiConsumer

andThen

Constructor Detail

DuplicateDetectingMessageHandlerDecorator

public DuplicateDetectingMessageHandlerDecorator(DuplicateMessageDetector duplicateMessageDetector)

Method Detail

accept

public void accept(SubscriberIdAndMessage subscriberIdAndMessage,
                   MessageHandlerDecoratorChain messageHandlerDecoratorChain)

Specified by:

accept in interface java.util.function.BiConsumer<SubscriberIdAndMessage,MessageHandlerDecoratorChain>

getOrder

public int getOrder()

Specified by:

getOrder in interface MessageHandlerDecorator