io.eventuate.tram.consumer.common

Interface DuplicateMessageDetector

All Known Implementing Classes:

NoopDuplicateMessageDetector, SqlTableBasedDuplicateMessageDetector, TransactionalNoopDuplicateMessageDetector

public interface DuplicateMessageDetector

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)

Method Detail

isDuplicate

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

doWithMessage

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