io.eventuate.tram.inmemory

Class InMemoryMessageProducer

java.lang.Object

io.eventuate.tram.inmemory.InMemoryMessageProducer

All Implemented Interfaces:

MessageProducerImplementation

public class InMemoryMessageProducer
extends java.lang.Object
implements MessageProducerImplementation

Constructor Summary

Constructors

Constructor and Description
InMemoryMessageProducer(InMemoryMessageConsumer messageConsumer, io.eventuate.common.id.IdGenerator idGenerator)

Method Summary

Modifier and Type	Method and Description
java.lang.String	generateMessageId()
void	send(Message message)
void	withContext(java.lang.Runnable runnable)

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryMessageProducer

public InMemoryMessageProducer(InMemoryMessageConsumer messageConsumer,
                               io.eventuate.common.id.IdGenerator idGenerator)

Method Detail

generateMessageId

public java.lang.String generateMessageId()

Specified by:

generateMessageId in interface MessageProducerImplementation

withContext

public void withContext(java.lang.Runnable runnable)

Specified by:

withContext in interface MessageProducerImplementation

send

public void send(Message message)

Specified by:

send in interface MessageProducerImplementation