io.eventuate.tram.consumer.common

Class NoopDuplicateMessageDetector

java.lang.Object

io.eventuate.tram.consumer.common.NoopDuplicateMessageDetector

All Implemented Interfaces:

DuplicateMessageDetector

public class NoopDuplicateMessageDetector
extends java.lang.Object
implements DuplicateMessageDetector

Constructor Summary

Constructors

Constructor and Description
NoopDuplicateMessageDetector()

Method Summary

Modifier and Type	Method and Description
void	doWithMessage(SubscriberIdAndMessage subscriberIdAndMessage, java.lang.Runnable callback)
boolean	isDuplicate(java.lang.String consumerId, java.lang.String messageId)

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopDuplicateMessageDetector

public NoopDuplicateMessageDetector()

Method Detail

isDuplicate

public boolean isDuplicate(java.lang.String consumerId,
                           java.lang.String messageId)

Specified by:

isDuplicate in interface DuplicateMessageDetector

doWithMessage

public void doWithMessage(SubscriberIdAndMessage subscriberIdAndMessage,
                          java.lang.Runnable callback)

Specified by:

doWithMessage in interface DuplicateMessageDetector