io.eventuate.tram.messaging.producer.jdbc

Class MessageProducerJdbcImpl

java.lang.Object

io.eventuate.tram.messaging.producer.jdbc.MessageProducerJdbcImpl

All Implemented Interfaces:

MessageProducerImplementation

public class MessageProducerJdbcImpl
extends java.lang.Object
implements MessageProducerImplementation

Constructor Summary

Constructors

Constructor and Description
MessageProducerJdbcImpl(io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations, io.eventuate.common.id.IdGenerator idGenerator, io.eventuate.common.jdbc.EventuateSchema eventuateSchema, java.lang.String currentTimeInMillisecondsSql)

Method Summary

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

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.messaging.producer.common.MessageProducerImplementation

withContext

Constructor Detail

MessageProducerJdbcImpl

public MessageProducerJdbcImpl(io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations,
                               io.eventuate.common.id.IdGenerator idGenerator,
                               io.eventuate.common.jdbc.EventuateSchema eventuateSchema,
                               java.lang.String currentTimeInMillisecondsSql)

Method Detail

generateMessageId

public java.lang.String generateMessageId()

Specified by:

generateMessageId in interface MessageProducerImplementation

send

public void send(Message message)

Specified by:

send in interface MessageProducerImplementation