Package ch.tocco.nice2.optional.rabbitmq.impl

Class RabbitMqAfterCommitListener

java.lang.Object

ch.tocco.nice2.persist.core.api.util.CollectingAfterCommitListener

ch.tocco.nice2.optional.rabbitmq.impl.RabbitMqAfterCommitListener

All Implemented Interfaces:

ContextListener, EntityListener, CommitListener, EventListener

@Component
public class RabbitMqAfterCommitListener
extends CollectingAfterCommitListener

Field Summary

Fields

Modifier and Type	Field	Description
String	exchangeName

Constructor Summary

Constructors

Constructor	Description
RabbitMqAfterCommitListener(CommandExecutor commandExecutor, org.slf4j.Logger logger, RabbitMqService rabbitMqService)

Method Summary

Modifier and Type	Method	Description
protected AfterCommitTask	getAfterCommitTask()
void	setExchangeName(String exchangeName)

Methods inherited from class ch.tocco.nice2.persist.core.api.util.CollectingAfterCommitListener

afterCommit, beforeCommit, contextDestroying, customizeMode, entityCreated, entityDeleted, entityUpdated, handleAfterCommit, setFutureCollector

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.tocco.nice2.persist.core.api.util.CommitListener

afterFlush, priority

Methods inherited from interface ch.tocco.nice2.persist.core.api.ContextListener

transactionStarted

Field Details

exchangeName

public String exchangeName

Constructor Details

RabbitMqAfterCommitListener

public RabbitMqAfterCommitListener(CommandExecutor commandExecutor,
 org.slf4j.Logger logger,
 RabbitMqService rabbitMqService)

Method Details

setExchangeName

@Value("${nice2.optional.rabbitmq.entity.exchangeName}")
public void setExchangeName(String exchangeName)

getAfterCommitTask

protected AfterCommitTask getAfterCommitTask()

Specified by:

getAfterCommitTask in class CollectingAfterCommitListener