Package com.onec.messaging

Class OutboxWriter

java.lang.Object

com.onec.messaging.OutboxWriter

public class OutboxWriter
extends Object

Constructor Summary

Constructors

Constructor	Description
OutboxWriter(org.jdbi.v3.core.Jdbi jdbi)

Method Summary

Modifier and Type	Method	Description
UUID	append(String aggregateType, String aggregateId, String eventType, String payload)
List<OutboxEvent>	findPending(int limit)
void	markPublished(UUID id)

Methods inherited from class java.lang.Object

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

Constructor Details

OutboxWriter

public OutboxWriter(org.jdbi.v3.core.Jdbi jdbi)

Method Details

append

public UUID append(String aggregateType,
 String aggregateId,
 String eventType,
 String payload)

findPending

public List<OutboxEvent> findPending(int limit)

markPublished

public void markPublished(UUID id)