io.eventuate.tram.events.publisher

Class DomainEventPublisherImpl

java.lang.Object

io.eventuate.tram.events.publisher.DomainEventPublisherImpl

All Implemented Interfaces:

DomainEventPublisher

public class DomainEventPublisherImpl
extends java.lang.Object
implements DomainEventPublisher

Constructor Summary

Constructors

Constructor and Description
DomainEventPublisherImpl(MessageProducer messageProducer, DomainEventNameMapping domainEventNameMapping)

Method Summary

Modifier and Type	Method and Description
static Message	makeMessageForDomainEvent(java.lang.String aggregateType, java.lang.Object aggregateId, java.util.Map<java.lang.String,java.lang.String> headers, DomainEvent event, java.lang.String eventType)
void	publish(java.lang.String aggregateType, java.lang.Object aggregateId, java.util.List<DomainEvent> domainEvents)
void	publish(java.lang.String aggregateType, java.lang.Object aggregateId, java.util.Map<java.lang.String,java.lang.String> headers, java.util.List<DomainEvent> domainEvents)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.eventuate.tram.events.publisher.DomainEventPublisher

publish

Constructor Detail

DomainEventPublisherImpl

public DomainEventPublisherImpl(MessageProducer messageProducer,
                                DomainEventNameMapping domainEventNameMapping)

Method Detail

publish

public void publish(java.lang.String aggregateType,
                    java.lang.Object aggregateId,
                    java.util.List<DomainEvent> domainEvents)

Specified by:

publish in interface DomainEventPublisher

publish

public void publish(java.lang.String aggregateType,
                    java.lang.Object aggregateId,
                    java.util.Map<java.lang.String,java.lang.String> headers,
                    java.util.List<DomainEvent> domainEvents)

Specified by:

publish in interface DomainEventPublisher

makeMessageForDomainEvent

public static Message makeMessageForDomainEvent(java.lang.String aggregateType,
                                                java.lang.Object aggregateId,
                                                java.util.Map<java.lang.String,java.lang.String> headers,
                                                DomainEvent event,
                                                java.lang.String eventType)