Package dev.getelements.elements.dao.mongo.guice

Class MongoTransactionBufferedEventPublisher

java.lang.Object

dev.getelements.elements.dao.mongo.guice.MongoTransactionBufferedEventPublisher

All Implemented Interfaces:

Consumer<Event>

public class MongoTransactionBufferedEventPublisher
extends Object
implements Consumer<Event>

Buffers events during a transaction and publishes them only if the transaction commits. In the event of a rollback, this clears all events being buffered as they are no longer valid.

Constructor Summary

Constructors

Constructor	Description
MongoTransactionBufferedEventPublisher()

Method Summary

Modifier and Type	Method	Description
void	accept(Event event)
ElementRegistry	getElementRegistry()
Transaction	getTransaction()
void	postCommit()
void	rollback()
void	setElementRegistry(ElementRegistry elementRegistry)
void	setTransaction(Transaction transaction)

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.Consumer

andThen

Constructor Details

MongoTransactionBufferedEventPublisher

public MongoTransactionBufferedEventPublisher()

Method Details

accept

public void accept(Event event)

Specified by:

accept in interface Consumer<Event>

postCommit

public void postCommit()

rollback

public void rollback()

getTransaction

public Transaction getTransaction()

setTransaction

@Inject
public void setTransaction(Transaction transaction)

getElementRegistry

public ElementRegistry getElementRegistry()

setElementRegistry

@Inject
public void setElementRegistry(@Named("dev.getelements.elements.sdk.element.registry.root")
 ElementRegistry elementRegistry)