io.eventuate.tram.consumer.jdbc

Class SqlTableBasedDuplicateMessageDetector

java.lang.Object

io.eventuate.tram.consumer.jdbc.SqlTableBasedDuplicateMessageDetector

All Implemented Interfaces:

DuplicateMessageDetector

public class SqlTableBasedDuplicateMessageDetector
extends java.lang.Object
implements DuplicateMessageDetector

Constructor Summary

Constructors

Constructor and Description
SqlTableBasedDuplicateMessageDetector(io.eventuate.common.jdbc.EventuateSchema eventuateSchema, java.lang.String currentTimeInMillisecondsSql, io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor, io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate)

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

SqlTableBasedDuplicateMessageDetector

public SqlTableBasedDuplicateMessageDetector(io.eventuate.common.jdbc.EventuateSchema eventuateSchema,
                                             java.lang.String currentTimeInMillisecondsSql,
                                             io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor,
                                             io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate)

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