A B C D E F G H I M N O P R S T U V W

A

AbstractAggregateDomainEventPublisher<A,E extends DomainEvent> - Class in io.eventuate.tram.events.aggregates

AbstractAggregateDomainEventPublisher(DomainEventPublisher, Class<A>, Function<A, Object>) - Constructor for class io.eventuate.tram.events.aggregates.AbstractAggregateDomainEventPublisher

accept(SubscriberIdAndMessage, MessageHandlerDecoratorChain) - Method in class io.eventuate.tram.consumer.common.DuplicateDetectingMessageHandlerDecorator

accept(SubscriberIdAndMessage, MessageHandlerDecoratorChain) - Method in class io.eventuate.tram.consumer.common.PrePostHandlerMessageHandlerDecorator

accept(SubscriberIdAndMessage, MessageHandlerDecoratorChain) - Method in class io.eventuate.tram.consumer.common.PrePostReceiveMessageHandlerDecorator

accept(SubscriberIdAndMessage, MessageHandlerDecoratorChain) - Method in class io.eventuate.tram.optimisticlocking.OptimisticLockingDecorator

accept(Message) - Method in class io.eventuate.tram.testutil.TestMessageConsumer

aggregate(String, Object) - Method in class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

AGGREGATE_ID - Static variable in class io.eventuate.tram.events.common.EventMessageHeaders

AGGREGATE_TYPE - Static variable in class io.eventuate.tram.events.common.EventMessageHeaders

andFinally(Consumer<SubscriberIdAndMessage>) - Method in class io.eventuate.tram.consumer.common.MessageHandlerDecoratorChainBuilder

andForAggregateType(String) - Method in class io.eventuate.tram.events.subscriber.DomainEventHandlersBuilder

andThen(MessageHandlerDecorator) - Method in class io.eventuate.tram.consumer.common.MessageHandlerDecoratorChainBuilder

assertCommandMessageSent(String, Class<C>) - Method in class io.eventuate.tram.testing.MessageTracker

assertDomainEventPublished(String, String) - Method in class io.eventuate.tram.testing.MessageTracker

assertDomainEventPublished(String, Class<C>) - Method in class io.eventuate.tram.testing.MessageTracker

assertHasReplyTo(String) - Method in class io.eventuate.tram.testutil.TestMessageConsumer

assertReplyTypeEquals(Class<?>, Message) - Static method in class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

B

body - Variable in class io.eventuate.tram.messaging.producer.MessageBuilder

build() - Method in class io.eventuate.tram.events.subscriber.DomainEventHandlersBuilder

build() - Method in class io.eventuate.tram.messaging.common.DefaultChannelMapping.DefaultChannelMappingBuilder

build() - Method in class io.eventuate.tram.messaging.producer.MessageBuilder

builder() - Static method in class io.eventuate.tram.messaging.common.DefaultChannelMapping

BuiltInMessageHandlerDecoratorOrder - Class in io.eventuate.tram.consumer.common

BuiltInMessageHandlerDecoratorOrder() - Constructor for class io.eventuate.tram.consumer.common.BuiltInMessageHandlerDecoratorOrder

C

ChannelMapping - Interface in io.eventuate.tram.messaging.common

channelMapping() - Method in class io.eventuate.tram.micronaut.messaging.common.TramMessagingCommonFactory

channelMapping() - Method in class io.eventuate.tram.spring.messaging.common.TramMessagingCommonAutoConfiguration

close() - Method in class io.eventuate.tram.consumer.activemq.EventuateTramActiveMQMessageConsumer

close() - Method in class io.eventuate.tram.consumer.common.MessageConsumerImpl

close() - Method in interface io.eventuate.tram.consumer.common.MessageConsumerImplementation

close() - Method in class io.eventuate.tram.consumer.kafka.EventuateTramKafkaMessageConsumer

close() - Method in class io.eventuate.tram.consumer.rabbitmq.EventuateTramRabbitMQMessageConsumer

close() - Method in class io.eventuate.tram.consumer.redis.EventuateTramRedisMessageConsumer

close() - Method in class io.eventuate.tram.inmemory.InMemoryMessageConsumer

close() - Method in interface io.eventuate.tram.messaging.consumer.MessageConsumer

commandHandlers(CommandHandlers) - Method in class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

CommandMessageHandlerUnitTestSupport - Class in io.eventuate.tram.testing.commands

CommandMessageHandlerUnitTestSupport() - Constructor for class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

containsReplyTo(String) - Method in class io.eventuate.tram.testutil.TestMessageConsumer

convert(Message) - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateContractVerifierMessaging

D

DATE - Static variable in interface io.eventuate.tram.messaging.common.Message

decorate(MessageHandler) - Method in class io.eventuate.tram.consumer.common.DecoratedMessageHandlerFactory

DecoratedMessageHandlerFactory - Class in io.eventuate.tram.consumer.common

DecoratedMessageHandlerFactory(List<MessageHandlerDecorator>) - Constructor for class io.eventuate.tram.consumer.common.DecoratedMessageHandlerFactory

DefaultChannelMapping - Class in io.eventuate.tram.messaging.common

DefaultChannelMapping(Map<String, String>) - Constructor for class io.eventuate.tram.messaging.common.DefaultChannelMapping

DefaultChannelMapping.DefaultChannelMappingBuilder - Class in io.eventuate.tram.messaging.common

DefaultChannelMappingBuilder() - Constructor for class io.eventuate.tram.messaging.common.DefaultChannelMapping.DefaultChannelMappingBuilder

DefaultDomainEventNameMapping - Class in io.eventuate.tram.events.common

DefaultDomainEventNameMapping() - Constructor for class io.eventuate.tram.events.common.DefaultDomainEventNameMapping

DESTINATION - Static variable in interface io.eventuate.tram.messaging.common.Message

dispatchMessage(Message) - Method in class io.eventuate.tram.inmemory.InMemoryMessageConsumer

DomainEvent - Interface in io.eventuate.tram.events.common

DomainEventDispatcher - Class in io.eventuate.tram.events.subscriber

DomainEventDispatcher(String, DomainEventHandlers, MessageConsumer, DomainEventNameMapping) - Constructor for class io.eventuate.tram.events.subscriber.DomainEventDispatcher

DomainEventDispatcherFactory - Class in io.eventuate.tram.events.subscriber

DomainEventDispatcherFactory(MessageConsumer, DomainEventNameMapping) - Constructor for class io.eventuate.tram.events.subscriber.DomainEventDispatcherFactory

domainEventDispatcherFactory(MessageConsumer, DomainEventNameMapping) - Method in class io.eventuate.tram.micronaut.events.subscriber.TramEventSubscriberFactory

domainEventDispatcherFactory(MessageConsumer, DomainEventNameMapping) - Method in class io.eventuate.tram.spring.events.subscriber.TramEventSubscriberConfiguration

DomainEventDispatcherInitializer - Class in io.eventuate.tram.micronaut.events.subscriber

DomainEventDispatcherInitializer(DomainEventDispatcher[]) - Constructor for class io.eventuate.tram.micronaut.events.subscriber.DomainEventDispatcherInitializer

DomainEventEnvelope<T extends DomainEvent> - Interface in io.eventuate.tram.events.subscriber

DomainEventEnvelopeImpl<T extends DomainEvent> - Class in io.eventuate.tram.events.subscriber

DomainEventEnvelopeImpl(Message, String, String, String, T) - Constructor for class io.eventuate.tram.events.subscriber.DomainEventEnvelopeImpl

DomainEventHandler - Class in io.eventuate.tram.events.subscriber

DomainEventHandler(String, Class<DomainEvent>, Consumer<DomainEventEnvelope<DomainEvent>>) - Constructor for class io.eventuate.tram.events.subscriber.DomainEventHandler

DomainEventHandlers - Class in io.eventuate.tram.events.subscriber

DomainEventHandlers(List<DomainEventHandler>) - Constructor for class io.eventuate.tram.events.subscriber.DomainEventHandlers

DomainEventHandlersBuilder - Class in io.eventuate.tram.events.subscriber

DomainEventHandlersBuilder(String) - Constructor for class io.eventuate.tram.events.subscriber.DomainEventHandlersBuilder

DomainEventHandlerUnitTestSupport - Class in io.eventuate.tram.testing

Provides a DSL for writing unit tests for domain event handlers

DomainEventHandlerUnitTestSupport() - Constructor for class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

DomainEventNameMapping - Interface in io.eventuate.tram.events.common

Maps between event class names and external event types

domainEventNameMapping - Variable in class io.eventuate.tram.events.subscriber.DomainEventDispatcherFactory

domainEventNameMapping() - Method in class io.eventuate.tram.micronaut.events.common.TramEventsCommonFactory

domainEventNameMapping() - Method in class io.eventuate.tram.spring.events.common.TramEventsCommonAutoConfiguration

DomainEventPublisher - Interface in io.eventuate.tram.events.publisher

domainEventPublisher(MessageProducer, DomainEventNameMapping) - Method in class io.eventuate.tram.micronaut.events.publisher.TramEventsPublisherFactory

domainEventPublisher(MessageProducer, DomainEventNameMapping) - Method in class io.eventuate.tram.spring.events.publisher.TramEventsPublisherConfiguration

DomainEventPublisherImpl - Class in io.eventuate.tram.events.publisher

DomainEventPublisherImpl(MessageProducer, DomainEventNameMapping) - Constructor for class io.eventuate.tram.events.publisher.DomainEventPublisherImpl

doWithMessage(SubscriberIdAndMessage, Runnable) - Method in interface io.eventuate.tram.consumer.common.DuplicateMessageDetector

doWithMessage(SubscriberIdAndMessage, Runnable) - Method in class io.eventuate.tram.consumer.common.NoopDuplicateMessageDetector

doWithMessage(SubscriberIdAndMessage, Runnable) - Method in class io.eventuate.tram.consumer.jdbc.SqlTableBasedDuplicateMessageDetector

doWithMessage(SubscriberIdAndMessage, Runnable) - Method in class io.eventuate.tram.consumer.jdbc.TransactionalNoopDuplicateMessageDetector

DUPLICATE_DETECTING_MESSAGE_HANDLER_DECORATOR - Static variable in class io.eventuate.tram.consumer.common.BuiltInMessageHandlerDecoratorOrder

DuplicateDetectingMessageHandlerDecorator - Class in io.eventuate.tram.consumer.common

DuplicateDetectingMessageHandlerDecorator(DuplicateMessageDetector) - Constructor for class io.eventuate.tram.consumer.common.DuplicateDetectingMessageHandlerDecorator

duplicateDetectingMessageHandlerDecorator(DuplicateMessageDetector) - Method in class io.eventuate.tram.micronaut.consumer.common.TramConsumerBaseCommonFactory

duplicateDetectingMessageHandlerDecorator(DuplicateMessageDetector) - Method in class io.eventuate.tram.spring.consumer.common.TramConsumerBaseCommonConfiguration

DuplicateMessageDetector - Interface in io.eventuate.tram.consumer.common

duplicateMessageDetector() - Method in class io.eventuate.tram.micronaut.consumer.common.TramNoopDuplicateMessageDetectorFactory

duplicateMessageDetector(String, EventuateSchema, SqlDialectSelector, EventuateJdbcStatementExecutor, EventuateTransactionTemplate) - Method in class io.eventuate.tram.micronaut.consumer.jdbc.TramConsumerJdbcFactory

duplicateMessageDetector(TransactionTemplate) - Method in class io.eventuate.tram.micronaut.consumer.jdbc.TransactionalNoopDuplicateMessageDetectorFactory

duplicateMessageDetector() - Method in class io.eventuate.tram.spring.consumer.common.TramNoopDuplicateMessageDetectorConfiguration

duplicateMessageDetector(EventuateSchema, SqlDialectSelector, EventuateJdbcStatementExecutor, EventuateTransactionTemplate) - Method in class io.eventuate.tram.spring.consumer.jdbc.TramConsumerJdbcAutoConfiguration

duplicateMessageDetector(TransactionTemplate) - Method in class io.eventuate.tram.spring.consumer.jdbc.TransactionalNoopDuplicateMessageDetectorConfiguration

E

EVENT_TYPE - Static variable in class io.eventuate.tram.events.common.EventMessageHeaders

eventHandlers(DomainEventHandlers) - Method in class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

EventMessageHeaders - Class in io.eventuate.tram.events.common

EventMessageHeaders() - Constructor for class io.eventuate.tram.events.common.EventMessageHeaders

events - Variable in class io.eventuate.tram.events.aggregates.ResultWithDomainEvents

events - Variable in class io.eventuate.tram.events.publisher.ResultWithEvents

eventToExternalEventType(String, DomainEvent) - Method in class io.eventuate.tram.events.common.DefaultDomainEventNameMapping

eventToExternalEventType(String, DomainEvent) - Method in interface io.eventuate.tram.events.common.DomainEventNameMapping

eventuateCommonInMemoryScriptSupplierForTram() - Method in class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

eventuateCommonInMemoryScriptSupplierForTram() - Method in class io.eventuate.tram.spring.inmemory.TramInMemoryCommonConfiguration

EventuateContractVerifierConfiguration - Class in io.eventuate.tram.spring.cloudcontractsupport

EventuateContractVerifierConfiguration() - Constructor for class io.eventuate.tram.spring.cloudcontractsupport.EventuateContractVerifierConfiguration

eventuateContractVerifierMessaging(MessageVerifier<Message>) - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateContractVerifierConfiguration

EventuateContractVerifierMessaging - Class in io.eventuate.tram.spring.cloudcontractsupport

EventuateContractVerifierMessaging(MessageVerifier<Message>) - Constructor for class io.eventuate.tram.spring.cloudcontractsupport.EventuateContractVerifierMessaging

EventuateTramActiveMQMessageConsumer - Class in io.eventuate.tram.consumer.activemq

EventuateTramActiveMQMessageConsumer(MessageConsumerActiveMQImpl) - Constructor for class io.eventuate.tram.consumer.activemq.EventuateTramActiveMQMessageConsumer

EventuateTramActiveMQMessageConsumerConfiguration - Class in io.eventuate.tram.consumer.activemq

EventuateTramActiveMQMessageConsumerConfiguration() - Constructor for class io.eventuate.tram.consumer.activemq.EventuateTramActiveMQMessageConsumerConfiguration

EventuateTramKafkaMessageConsumer - Class in io.eventuate.tram.consumer.kafka

EventuateTramKafkaMessageConsumer(MessageConsumerKafkaImpl) - Constructor for class io.eventuate.tram.consumer.kafka.EventuateTramKafkaMessageConsumer

EventuateTramKafkaMessageConsumerConfiguration - Class in io.eventuate.tram.spring.consumer.kafka

EventuateTramKafkaMessageConsumerConfiguration() - Constructor for class io.eventuate.tram.spring.consumer.kafka.EventuateTramKafkaMessageConsumerConfiguration

EventuateTramKafkaMessageConsumerFactory - Class in io.eventuate.tram.micronaut.consumer.kafka

EventuateTramKafkaMessageConsumerFactory() - Constructor for class io.eventuate.tram.micronaut.consumer.kafka.EventuateTramKafkaMessageConsumerFactory

eventuateTramMessageVerifier() - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateContractVerifierConfiguration

EventuateTramMessageVerifier - Class in io.eventuate.tram.spring.cloudcontractsupport

EventuateTramMessageVerifier() - Constructor for class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramMessageVerifier

EventuateTramRabbitMQMessageConsumer - Class in io.eventuate.tram.consumer.rabbitmq

EventuateTramRabbitMQMessageConsumer(MessageConsumerRabbitMQImpl) - Constructor for class io.eventuate.tram.consumer.rabbitmq.EventuateTramRabbitMQMessageConsumer

EventuateTramRabbitMQMessageConsumerConfiguration - Class in io.eventuate.tram.consumer.rabbitmq

EventuateTramRabbitMQMessageConsumerConfiguration() - Constructor for class io.eventuate.tram.consumer.rabbitmq.EventuateTramRabbitMQMessageConsumerConfiguration

EventuateTramRedisMessageConsumer - Class in io.eventuate.tram.consumer.redis

EventuateTramRedisMessageConsumer(MessageConsumerRedisImpl) - Constructor for class io.eventuate.tram.consumer.redis.EventuateTramRedisMessageConsumer

EventuateTramRedisMessageConsumerConfiguration - Class in io.eventuate.tram.consumer.redis

EventuateTramRedisMessageConsumerConfiguration() - Constructor for class io.eventuate.tram.consumer.redis.EventuateTramRedisMessageConsumerConfiguration

EventuateTramRoutesConfigurer - Class in io.eventuate.tram.spring.cloudcontractsupport

EventuateTramRoutesConfigurer(BatchStubRunner) - Constructor for class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramRoutesConfigurer

externalEventTypeToEventClassName(String, String) - Method in class io.eventuate.tram.events.common.DefaultDomainEventNameMapping

externalEventTypeToEventClassName(String, String) - Method in interface io.eventuate.tram.events.common.DomainEventNameMapping

F

findTargetMethod(Message) - Method in class io.eventuate.tram.events.subscriber.DomainEventHandlers

forAggregateType(String) - Static method in class io.eventuate.tram.events.subscriber.DomainEventHandlersBuilder

G

generateMessageId() - Method in class io.eventuate.tram.inmemory.InMemoryMessageProducer

generateMessageId() - Method in interface io.eventuate.tram.messaging.producer.common.MessageProducerImplementation

generateMessageId() - Method in class io.eventuate.tram.messaging.producer.jdbc.MessageProducerJdbcImpl

get(String) - Method in interface io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderAccessor

get(MessageHeaderAccessor, String) - Method in class io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderPropagation

getAggregateId() - Method in interface io.eventuate.tram.events.subscriber.DomainEventEnvelope

getAggregateId() - Method in class io.eventuate.tram.events.subscriber.DomainEventEnvelopeImpl

getAggregateType() - Method in class io.eventuate.tram.events.aggregates.AbstractAggregateDomainEventPublisher

getAggregateType() - Method in interface io.eventuate.tram.events.subscriber.DomainEventEnvelope

getAggregateType() - Method in class io.eventuate.tram.events.subscriber.DomainEventEnvelopeImpl

getAggregateType() - Method in class io.eventuate.tram.events.subscriber.DomainEventHandler

getAggregateTypesAndEvents() - Method in class io.eventuate.tram.events.subscriber.DomainEventHandlers

getEvent() - Method in interface io.eventuate.tram.events.subscriber.DomainEventEnvelope

getEvent() - Method in class io.eventuate.tram.events.subscriber.DomainEventEnvelopeImpl

getEventClass() - Method in class io.eventuate.tram.events.subscriber.DomainEventHandler

getEventId() - Method in interface io.eventuate.tram.events.subscriber.DomainEventEnvelope

getEventId() - Method in class io.eventuate.tram.events.subscriber.DomainEventEnvelopeImpl

getHandlers() - Method in class io.eventuate.tram.events.subscriber.DomainEventHandlers

getHeader(String) - Method in interface io.eventuate.tram.messaging.common.Message

getHeader(String) - Method in class io.eventuate.tram.messaging.common.MessageImpl

getHeaders() - Method in interface io.eventuate.tram.messaging.common.Message

getHeaders() - Method in class io.eventuate.tram.messaging.common.MessageImpl

getId() - Method in class io.eventuate.tram.consumer.activemq.EventuateTramActiveMQMessageConsumer

getId() - Method in class io.eventuate.tram.consumer.common.MessageConsumerImpl

getId() - Method in interface io.eventuate.tram.consumer.common.MessageConsumerImplementation

getId() - Method in class io.eventuate.tram.consumer.kafka.EventuateTramKafkaMessageConsumer

getId() - Method in class io.eventuate.tram.consumer.rabbitmq.EventuateTramRabbitMQMessageConsumer

getId() - Method in class io.eventuate.tram.consumer.redis.EventuateTramRedisMessageConsumer

getId() - Method in class io.eventuate.tram.inmemory.InMemoryMessageConsumer

getId() - Method in interface io.eventuate.tram.messaging.common.Message

getId() - Method in class io.eventuate.tram.messaging.common.MessageImpl

getId() - Method in interface io.eventuate.tram.messaging.consumer.MessageConsumer

getMessage() - Method in class io.eventuate.tram.consumer.common.SubscriberIdAndMessage

getMessage() - Method in interface io.eventuate.tram.events.subscriber.DomainEventEnvelope

getMessage() - Method in class io.eventuate.tram.events.subscriber.DomainEventEnvelopeImpl

getMessageHandler() - Method in class io.eventuate.tram.inmemory.MessageHandlerWithSubscriberId

getOrder() - Method in class io.eventuate.tram.consumer.common.DuplicateDetectingMessageHandlerDecorator

getOrder() - Method in interface io.eventuate.tram.consumer.common.MessageHandlerDecorator

getOrder() - Method in class io.eventuate.tram.consumer.common.PrePostHandlerMessageHandlerDecorator

getOrder() - Method in class io.eventuate.tram.consumer.common.PrePostReceiveMessageHandlerDecorator

getOrder() - Method in class io.eventuate.tram.optimisticlocking.OptimisticLockingDecorator

getPayload() - Method in interface io.eventuate.tram.messaging.common.Message

getPayload() - Method in class io.eventuate.tram.messaging.common.MessageImpl

getReplyChannel() - Method in class io.eventuate.tram.testutil.TestMessageConsumer

getRequiredHeader(String) - Method in interface io.eventuate.tram.messaging.common.Message

getRequiredHeader(String) - Method in class io.eventuate.tram.messaging.common.MessageImpl

getSubscriber() - Method in class io.eventuate.tram.inmemory.MessageHandlerWithSubscriberId

getSubscriberId() - Method in class io.eventuate.tram.consumer.common.SubscriberIdAndMessage

given() - Static method in class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

given() - Static method in class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

H

handles(Message) - Method in class io.eventuate.tram.events.subscriber.DomainEventHandler

hasHeader(String) - Method in interface io.eventuate.tram.messaging.common.Message

hasHeader(String) - Method in class io.eventuate.tram.messaging.common.MessageImpl

headers - Variable in class io.eventuate.tram.messaging.producer.MessageBuilder

HttpDateHeaderFormatUtil - Class in io.eventuate.tram.messaging.producer.common

HttpDateHeaderFormatUtil() - Constructor for class io.eventuate.tram.messaging.producer.common.HttpDateHeaderFormatUtil

I

ID - Static variable in interface io.eventuate.tram.messaging.common.Message

idGenerator() - Method in class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

idGenerator() - Method in class io.eventuate.tram.micronaut.messaging.producer.jdbc.TramMessageProducerJdbcFactory

idGenerator() - Method in class io.eventuate.tram.spring.inmemory.TramInMemoryCommonConfiguration

idGenerator() - Method in class io.eventuate.tram.spring.messaging.producer.jdbc.TramMessageProducerJdbcConfiguration

init() - Method in class io.eventuate.tram.micronaut.events.subscriber.DomainEventDispatcherInitializer

initialize() - Method in class io.eventuate.tram.events.subscriber.DomainEventDispatcher

initialize() - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramRoutesConfigurer

InMemoryMessageConsumer - Class in io.eventuate.tram.inmemory

InMemoryMessageConsumer() - Constructor for class io.eventuate.tram.inmemory.InMemoryMessageConsumer

inMemoryMessageConsumer() - Method in class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

inMemoryMessageConsumer() - Method in class io.eventuate.tram.spring.inmemory.TramInMemoryCommonConfiguration

InMemoryMessageProducer - Class in io.eventuate.tram.inmemory

InMemoryMessageProducer(InMemoryMessageConsumer, IdGenerator) - Constructor for class io.eventuate.tram.inmemory.InMemoryMessageProducer

inMemoryMessageProducer(InMemoryMessageConsumer, IdGenerator) - Method in class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

inMemoryMessageProducer(InMemoryMessageConsumer, IdGenerator) - Method in class io.eventuate.tram.spring.inmemory.TramInMemoryCommonConfiguration

INSTANCE - Static variable in class io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderPropagation

invoke(DomainEventEnvelope<DomainEvent>) - Method in class io.eventuate.tram.events.subscriber.DomainEventHandler

invokeNext(SubscriberIdAndMessage) - Method in interface io.eventuate.tram.consumer.common.MessageHandlerDecoratorChain

io.eventuate.tram.consumer.activemq - package io.eventuate.tram.consumer.activemq

io.eventuate.tram.consumer.common - package io.eventuate.tram.consumer.common

io.eventuate.tram.consumer.jdbc - package io.eventuate.tram.consumer.jdbc

io.eventuate.tram.consumer.kafka - package io.eventuate.tram.consumer.kafka

io.eventuate.tram.consumer.rabbitmq - package io.eventuate.tram.consumer.rabbitmq

io.eventuate.tram.consumer.redis - package io.eventuate.tram.consumer.redis

io.eventuate.tram.events.aggregates - package io.eventuate.tram.events.aggregates

io.eventuate.tram.events.common - package io.eventuate.tram.events.common

io.eventuate.tram.events.publisher - package io.eventuate.tram.events.publisher

io.eventuate.tram.events.subscriber - package io.eventuate.tram.events.subscriber

io.eventuate.tram.inmemory - package io.eventuate.tram.inmemory

io.eventuate.tram.integrationtest.common - package io.eventuate.tram.integrationtest.common

io.eventuate.tram.jdbcactivemq - package io.eventuate.tram.jdbcactivemq

io.eventuate.tram.jdbcrabbitmq - package io.eventuate.tram.jdbcrabbitmq

io.eventuate.tram.jdbcredis - package io.eventuate.tram.jdbcredis

io.eventuate.tram.messaging.common - package io.eventuate.tram.messaging.common

io.eventuate.tram.messaging.consumer - package io.eventuate.tram.messaging.consumer

io.eventuate.tram.messaging.producer - package io.eventuate.tram.messaging.producer

io.eventuate.tram.messaging.producer.common - package io.eventuate.tram.messaging.producer.common

io.eventuate.tram.messaging.producer.jdbc - package io.eventuate.tram.messaging.producer.jdbc

io.eventuate.tram.micronaut.consumer.common - package io.eventuate.tram.micronaut.consumer.common

io.eventuate.tram.micronaut.consumer.jdbc - package io.eventuate.tram.micronaut.consumer.jdbc

io.eventuate.tram.micronaut.consumer.kafka - package io.eventuate.tram.micronaut.consumer.kafka

io.eventuate.tram.micronaut.events.common - package io.eventuate.tram.micronaut.events.common

io.eventuate.tram.micronaut.events.publisher - package io.eventuate.tram.micronaut.events.publisher

io.eventuate.tram.micronaut.events.subscriber - package io.eventuate.tram.micronaut.events.subscriber

io.eventuate.tram.micronaut.inmemory - package io.eventuate.tram.micronaut.inmemory

io.eventuate.tram.micronaut.messaging.common - package io.eventuate.tram.micronaut.messaging.common

io.eventuate.tram.micronaut.messaging.producer.common - package io.eventuate.tram.micronaut.messaging.producer.common

io.eventuate.tram.micronaut.messaging.producer.jdbc - package io.eventuate.tram.micronaut.messaging.producer.jdbc

io.eventuate.tram.optimisticlocking - package io.eventuate.tram.optimisticlocking

io.eventuate.tram.spring.cloudcontractsupport - package io.eventuate.tram.spring.cloudcontractsupport

io.eventuate.tram.spring.cloudsleuthintegration - package io.eventuate.tram.spring.cloudsleuthintegration

io.eventuate.tram.spring.consumer.common - package io.eventuate.tram.spring.consumer.common

io.eventuate.tram.spring.consumer.jdbc - package io.eventuate.tram.spring.consumer.jdbc

io.eventuate.tram.spring.consumer.kafka - package io.eventuate.tram.spring.consumer.kafka

io.eventuate.tram.spring.events.common - package io.eventuate.tram.spring.events.common

io.eventuate.tram.spring.events.publisher - package io.eventuate.tram.spring.events.publisher

io.eventuate.tram.spring.events.subscriber - package io.eventuate.tram.spring.events.subscriber

io.eventuate.tram.spring.inmemory - package io.eventuate.tram.spring.inmemory

io.eventuate.tram.spring.jdbckafka - package io.eventuate.tram.spring.jdbckafka

io.eventuate.tram.spring.messaging.common - package io.eventuate.tram.spring.messaging.common

io.eventuate.tram.spring.messaging.producer.common - package io.eventuate.tram.spring.messaging.producer.common

io.eventuate.tram.spring.messaging.producer.jdbc - package io.eventuate.tram.spring.messaging.producer.jdbc

io.eventuate.tram.testing - package io.eventuate.tram.testing

io.eventuate.tram.testing.commands - package io.eventuate.tram.testing.commands

io.eventuate.tram.testutil - package io.eventuate.tram.testutil

isDuplicate(String, String) - Method in interface io.eventuate.tram.consumer.common.DuplicateMessageDetector

isDuplicate(String, String) - Method in class io.eventuate.tram.consumer.common.NoopDuplicateMessageDetector

isDuplicate(String, String) - Method in class io.eventuate.tram.consumer.jdbc.SqlTableBasedDuplicateMessageDetector

isDuplicate(String, String) - Method in class io.eventuate.tram.consumer.jdbc.TransactionalNoopDuplicateMessageDetector

M

make(String, DomainEventHandlers) - Method in class io.eventuate.tram.events.subscriber.DomainEventDispatcherFactory

make(String, DomainEventHandlers) - Method in class io.eventuate.tram.spring.events.subscriber.SpringDomainEventDispatcherFactory

make() - Method in class io.eventuate.tram.testutil.TestMessageConsumerFactory

makeMessageForDomainEvent(String, Object, Map<String, String>, DomainEvent, String) - Static method in class io.eventuate.tram.events.publisher.DomainEventPublisherImpl

matches(ConditionContext, AnnotatedTypeMetadata) - Method in class io.eventuate.tram.integrationtest.common.MySqlBinlogKafkaCondition

matches(ConditionContext, AnnotatedTypeMetadata) - Method in class io.eventuate.tram.integrationtest.common.MySqlBinlogRedisCondition

matches(ConditionContext, AnnotatedTypeMetadata) - Method in class io.eventuate.tram.integrationtest.common.PollingActiveMQCondition

matches(ConditionContext, AnnotatedTypeMetadata) - Method in class io.eventuate.tram.integrationtest.common.PostgresWalRabbitMQCondition

Message - Interface in io.eventuate.tram.messaging.common

A message

MessageBuilder - Class in io.eventuate.tram.messaging.producer

Builds a message

MessageBuilder() - Constructor for class io.eventuate.tram.messaging.producer.MessageBuilder

MessageBuilder(String) - Constructor for class io.eventuate.tram.messaging.producer.MessageBuilder

MessageBuilder(Message) - Constructor for class io.eventuate.tram.messaging.producer.MessageBuilder

messageConsumer - Variable in class io.eventuate.tram.events.subscriber.DomainEventDispatcherFactory

MessageConsumer - Interface in io.eventuate.tram.messaging.consumer

messageConsumer(MessageConsumerImplementation, ChannelMapping, DecoratedMessageHandlerFactory) - Method in class io.eventuate.tram.micronaut.consumer.common.TramConsumerCommonFactory

messageConsumer(MessageConsumerImplementation, ChannelMapping, DecoratedMessageHandlerFactory) - Method in class io.eventuate.tram.spring.consumer.common.TramConsumerCommonConfiguration

MessageConsumerImpl - Class in io.eventuate.tram.consumer.common

MessageConsumerImpl(ChannelMapping, MessageConsumerImplementation, DecoratedMessageHandlerFactory) - Constructor for class io.eventuate.tram.consumer.common.MessageConsumerImpl

messageConsumerImplementation(MessageConsumerActiveMQImpl) - Method in class io.eventuate.tram.consumer.activemq.EventuateTramActiveMQMessageConsumerConfiguration

MessageConsumerImplementation - Interface in io.eventuate.tram.consumer.common

messageConsumerImplementation(MessageConsumerRabbitMQImpl) - Method in class io.eventuate.tram.consumer.rabbitmq.EventuateTramRabbitMQMessageConsumerConfiguration

messageConsumerImplementation(MessageConsumerRedisImpl) - Method in class io.eventuate.tram.consumer.redis.EventuateTramRedisMessageConsumerConfiguration

messageConsumerImplementation(MessageConsumerKafkaImpl) - Method in class io.eventuate.tram.micronaut.consumer.kafka.EventuateTramKafkaMessageConsumerFactory

messageConsumerImplementation(InMemoryMessageConsumer) - Method in class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

messageConsumerImplementation(MessageConsumerKafkaImpl) - Method in class io.eventuate.tram.spring.consumer.kafka.EventuateTramKafkaMessageConsumerConfiguration

messageHandler(Message) - Method in class io.eventuate.tram.events.subscriber.DomainEventDispatcher

MessageHandler - Interface in io.eventuate.tram.messaging.consumer

MessageHandlerDecorator - Interface in io.eventuate.tram.consumer.common

MessageHandlerDecoratorChain - Interface in io.eventuate.tram.consumer.common

MessageHandlerDecoratorChainBuilder - Class in io.eventuate.tram.consumer.common

MessageHandlerDecoratorChainBuilder() - Constructor for class io.eventuate.tram.consumer.common.MessageHandlerDecoratorChainBuilder

MessageHandlerWithSubscriberId - Class in io.eventuate.tram.inmemory

MessageHandlerWithSubscriberId(String, Consumer<SubscriberIdAndMessage>) - Constructor for class io.eventuate.tram.inmemory.MessageHandlerWithSubscriberId

MessageHeaderAccessor - Interface in io.eventuate.tram.spring.cloudsleuthintegration

MessageHeaderPropagation - Class in io.eventuate.tram.spring.cloudsleuthintegration

MessageHeaderPropagation() - Constructor for class io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderPropagation

MessageImpl - Class in io.eventuate.tram.messaging.common

MessageImpl() - Constructor for class io.eventuate.tram.messaging.common.MessageImpl

MessageImpl(String, Map<String, String>) - Constructor for class io.eventuate.tram.messaging.common.MessageImpl

MessageInterceptor - Interface in io.eventuate.tram.messaging.common

MessageProducer - Interface in io.eventuate.tram.messaging.producer

messageProducer(MessageInterceptor[], ChannelMapping, MessageProducerImplementation) - Method in class io.eventuate.tram.micronaut.messaging.producer.common.TramMessagingCommonProducerFactory

messageProducer(ChannelMapping, MessageProducerImplementation) - Method in class io.eventuate.tram.spring.messaging.producer.common.TramMessagingCommonProducerConfiguration

MessageProducerImpl - Class in io.eventuate.tram.messaging.producer.common

MessageProducerImpl(MessageInterceptor[], ChannelMapping, MessageProducerImplementation) - Constructor for class io.eventuate.tram.messaging.producer.common.MessageProducerImpl

MessageProducerImplementation - Interface in io.eventuate.tram.messaging.producer.common

messageProducerImplementation(InMemoryMessageProducer) - Method in class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

messageProducerImplementation(String, EventuateCommonJdbcOperations, IdGenerator, EventuateSchema, SqlDialectSelector) - Method in class io.eventuate.tram.micronaut.messaging.producer.jdbc.TramMessageProducerJdbcFactory

messageProducerImplementation(EventuateCommonJdbcOperations, IdGenerator, EventuateSchema, SqlDialectSelector) - Method in class io.eventuate.tram.spring.messaging.producer.jdbc.TramMessageProducerJdbcConfiguration

MessageProducerJdbcImpl - Class in io.eventuate.tram.messaging.producer.jdbc

MessageProducerJdbcImpl(EventuateCommonJdbcOperations, IdGenerator, EventuateSchema, String) - Constructor for class io.eventuate.tram.messaging.producer.jdbc.MessageProducerJdbcImpl

MessageSubscription - Interface in io.eventuate.tram.messaging.consumer

MessageTracker - Class in io.eventuate.tram.testing

Subscribes to a specified set of channels Provides methods for asserting that a command or event was received

MessageTracker(Set<String>, MessageConsumer) - Constructor for class io.eventuate.tram.testing.MessageTracker

MySqlBinlogKafkaCondition - Class in io.eventuate.tram.integrationtest.common

MySqlBinlogKafkaCondition() - Constructor for class io.eventuate.tram.integrationtest.common.MySqlBinlogKafkaCondition

MySqlBinlogRedisCondition - Class in io.eventuate.tram.integrationtest.common

MySqlBinlogRedisCondition() - Constructor for class io.eventuate.tram.integrationtest.common.MySqlBinlogRedisCondition

N

NoopDuplicateMessageDetector - Class in io.eventuate.tram.consumer.common

NoopDuplicateMessageDetector() - Constructor for class io.eventuate.tram.consumer.common.NoopDuplicateMessageDetector

O

onEvent(Class<E>, Consumer<DomainEventEnvelope<E>>) - Method in class io.eventuate.tram.events.subscriber.DomainEventHandlersBuilder

OptimisticLockingDecorator - Class in io.eventuate.tram.optimisticlocking

OptimisticLockingDecorator() - Constructor for class io.eventuate.tram.optimisticlocking.OptimisticLockingDecorator

optimisticLockingDecorator() - Method in class io.eventuate.tram.optimisticlocking.OptimisticLockingDecoratorConfiguration

OptimisticLockingDecoratorConfiguration - Class in io.eventuate.tram.optimisticlocking

OptimisticLockingDecoratorConfiguration() - Constructor for class io.eventuate.tram.optimisticlocking.OptimisticLockingDecoratorConfiguration

P

PARTITION_ID - Static variable in interface io.eventuate.tram.messaging.common.Message

platformTransactionManager(DataSource) - Method in class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

PollingActiveMQCondition - Class in io.eventuate.tram.integrationtest.common

PollingActiveMQCondition() - Constructor for class io.eventuate.tram.integrationtest.common.PollingActiveMQCondition

PostgresWalRabbitMQCondition - Class in io.eventuate.tram.integrationtest.common

PostgresWalRabbitMQCondition() - Constructor for class io.eventuate.tram.integrationtest.common.PostgresWalRabbitMQCondition

postHandle(String, Message, Throwable) - Method in interface io.eventuate.tram.messaging.common.MessageInterceptor

postHandle(String, Message, Throwable) - Method in class io.eventuate.tram.spring.cloudsleuthintegration.TracingMessagingInterceptor

postReceive(Message) - Method in interface io.eventuate.tram.messaging.common.MessageInterceptor

postSend(Message, Exception) - Method in interface io.eventuate.tram.messaging.common.MessageInterceptor

postSend(Message, Exception) - Method in class io.eventuate.tram.spring.cloudsleuthintegration.TracingMessagingInterceptor

PRE_POST_HANDLER_MESSAGE_HANDLER_DECORATOR - Static variable in class io.eventuate.tram.consumer.common.BuiltInMessageHandlerDecoratorOrder

PRE_POST_RECEIVE_MESSAGE_HANDLER_DECORATOR - Static variable in class io.eventuate.tram.consumer.common.BuiltInMessageHandlerDecoratorOrder

preHandle(String, Message) - Method in interface io.eventuate.tram.messaging.common.MessageInterceptor

preHandle(String, Message) - Method in class io.eventuate.tram.spring.cloudsleuthintegration.TracingMessagingInterceptor

prepareMessageHeaders(String, Message) - Method in class io.eventuate.tram.messaging.producer.common.MessageProducerImpl

PrePostHandlerMessageHandlerDecorator - Class in io.eventuate.tram.consumer.common

PrePostHandlerMessageHandlerDecorator(MessageInterceptor[]) - Constructor for class io.eventuate.tram.consumer.common.PrePostHandlerMessageHandlerDecorator

prePostHandlerMessageHandlerDecorator(MessageInterceptor[]) - Method in class io.eventuate.tram.micronaut.consumer.common.TramConsumerBaseCommonFactory

prePostHandlerMessageHandlerDecorator() - Method in class io.eventuate.tram.spring.consumer.common.TramConsumerBaseCommonConfiguration

PrePostReceiveMessageHandlerDecorator - Class in io.eventuate.tram.consumer.common

PrePostReceiveMessageHandlerDecorator(MessageInterceptor[]) - Constructor for class io.eventuate.tram.consumer.common.PrePostReceiveMessageHandlerDecorator

prePostReceiveMessageHandlerDecoratorDecorator(MessageInterceptor[]) - Method in class io.eventuate.tram.micronaut.consumer.common.TramConsumerBaseCommonFactory

prePostReceiveMessageHandlerDecoratorDecorator() - Method in class io.eventuate.tram.spring.consumer.common.TramConsumerBaseCommonConfiguration

preReceive(Message) - Method in interface io.eventuate.tram.messaging.common.MessageInterceptor

preSend(Message) - Method in interface io.eventuate.tram.messaging.common.MessageInterceptor

preSend(Message) - Method in class io.eventuate.tram.spring.cloudsleuthintegration.TracingMessagingInterceptor

publish(A, List<E>) - Method in class io.eventuate.tram.events.aggregates.AbstractAggregateDomainEventPublisher

publish(String, Object, List<DomainEvent>) - Method in interface io.eventuate.tram.events.publisher.DomainEventPublisher

publish(String, Object, Map<String, String>, List<DomainEvent>) - Method in interface io.eventuate.tram.events.publisher.DomainEventPublisher

publish(Class<?>, Object, List<DomainEvent>) - Method in interface io.eventuate.tram.events.publisher.DomainEventPublisher

publish(String, Object, List<DomainEvent>) - Method in class io.eventuate.tram.events.publisher.DomainEventPublisherImpl

publish(String, Object, Map<String, String>, List<DomainEvent>) - Method in class io.eventuate.tram.events.publisher.DomainEventPublisherImpl

publishes(DomainEvent) - Method in class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

put(String, String) - Method in interface io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderAccessor

put(MessageHeaderAccessor, String, String) - Method in class io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderPropagation

R

receive(String, long, TimeUnit) - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramMessageVerifier

receive(String) - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramMessageVerifier

receives(Command) - Method in class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

remove(String) - Method in interface io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderAccessor

removeAnyTraceHeaders(MessageHeaderAccessor, List<String>) - Static method in class io.eventuate.tram.spring.cloudsleuthintegration.MessageHeaderPropagation

removeHeader(String) - Method in interface io.eventuate.tram.messaging.common.Message

removeHeader(String) - Method in class io.eventuate.tram.messaging.common.MessageImpl

reset() - Method in class io.eventuate.tram.testing.MessageTracker

result - Variable in class io.eventuate.tram.events.aggregates.ResultWithDomainEvents

result - Variable in class io.eventuate.tram.events.publisher.ResultWithEvents

ResultWithDomainEvents<A,E extends DomainEvent> - Class in io.eventuate.tram.events.aggregates

ResultWithDomainEvents(A, List<E>) - Constructor for class io.eventuate.tram.events.aggregates.ResultWithDomainEvents

ResultWithDomainEvents(A, E...) - Constructor for class io.eventuate.tram.events.aggregates.ResultWithDomainEvents

ResultWithEvents<T> - Class in io.eventuate.tram.events.publisher

ResultWithEvents(T, List<DomainEvent>) - Constructor for class io.eventuate.tram.events.publisher.ResultWithEvents

ResultWithEvents(T, DomainEvent...) - Constructor for class io.eventuate.tram.events.publisher.ResultWithEvents

S

send(Message) - Method in class io.eventuate.tram.inmemory.InMemoryMessageProducer

send(String, Message) - Method in class io.eventuate.tram.messaging.producer.common.MessageProducerImpl

send(Message) - Method in class io.eventuate.tram.messaging.producer.common.MessageProducerImpl

send(Message) - Method in interface io.eventuate.tram.messaging.producer.common.MessageProducerImplementation

send(Message) - Method in class io.eventuate.tram.messaging.producer.jdbc.MessageProducerJdbcImpl

send(String, Message) - Method in interface io.eventuate.tram.messaging.producer.MessageProducer

Send a message

send(Message, String) - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramMessageVerifier

send(T, Map<String, Object>, String) - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramMessageVerifier

setHeader(String, String) - Method in interface io.eventuate.tram.messaging.common.Message

setHeader(String, String) - Method in class io.eventuate.tram.messaging.common.MessageImpl

setHeaders(Map<String, String>) - Method in interface io.eventuate.tram.messaging.common.Message

setHeaders(Map<String, String>) - Method in class io.eventuate.tram.messaging.common.MessageImpl

setPayload(String) - Method in interface io.eventuate.tram.messaging.common.Message

setPayload(String) - Method in class io.eventuate.tram.messaging.common.MessageImpl

SpringDomainEventDispatcherFactory - Class in io.eventuate.tram.spring.events.subscriber

SpringDomainEventDispatcherFactory(MessageConsumer, DomainEventNameMapping) - Constructor for class io.eventuate.tram.spring.events.subscriber.SpringDomainEventDispatcherFactory

SqlTableBasedDuplicateMessageDetector - Class in io.eventuate.tram.consumer.jdbc

SqlTableBasedDuplicateMessageDetector(EventuateSchema, String, EventuateJdbcStatementExecutor, EventuateTransactionTemplate) - Constructor for class io.eventuate.tram.consumer.jdbc.SqlTableBasedDuplicateMessageDetector

startingWith(MessageHandlerDecorator) - Static method in class io.eventuate.tram.consumer.common.MessageHandlerDecoratorChainBuilder

subscribe(String, Set<String>, MessageHandler) - Method in class io.eventuate.tram.consumer.activemq.EventuateTramActiveMQMessageConsumer

subscribe(String, Set<String>, MessageHandler) - Method in class io.eventuate.tram.consumer.common.MessageConsumerImpl

subscribe(String, Set<String>, MessageHandler) - Method in interface io.eventuate.tram.consumer.common.MessageConsumerImplementation

subscribe(String, Set<String>, MessageHandler) - Method in class io.eventuate.tram.consumer.kafka.EventuateTramKafkaMessageConsumer

subscribe(String, Set<String>, MessageHandler) - Method in class io.eventuate.tram.consumer.rabbitmq.EventuateTramRabbitMQMessageConsumer

subscribe(String, Set<String>, MessageHandler) - Method in class io.eventuate.tram.consumer.redis.EventuateTramRedisMessageConsumer

subscribe(String, Set<String>, MessageHandler) - Method in class io.eventuate.tram.inmemory.InMemoryMessageConsumer

subscribe(String, Set<String>, MessageHandler) - Method in interface io.eventuate.tram.messaging.consumer.MessageConsumer

subscribe() - Method in class io.eventuate.tram.spring.cloudcontractsupport.EventuateTramMessageVerifier

subscribedMessageHandlerChainFactory(List<MessageHandlerDecorator>) - Method in class io.eventuate.tram.micronaut.consumer.common.TramConsumerBaseCommonFactory

subscribedMessageHandlerChainFactory(List<MessageHandlerDecorator>) - Method in class io.eventuate.tram.spring.consumer.common.TramConsumerBaseCommonConfiguration

SubscriberIdAndMessage - Class in io.eventuate.tram.consumer.common

SubscriberIdAndMessage(String, Message) - Constructor for class io.eventuate.tram.consumer.common.SubscriberIdAndMessage

T

TestMessageConsumer - Class in io.eventuate.tram.testutil

TestMessageConsumer(String) - Constructor for class io.eventuate.tram.testutil.TestMessageConsumer

TestMessageConsumerFactory - Class in io.eventuate.tram.testutil

TestMessageConsumerFactory() - Constructor for class io.eventuate.tram.testutil.TestMessageConsumerFactory

then() - Method in class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

then() - Method in class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

toString() - Method in class io.eventuate.tram.events.subscriber.DomainEventEnvelopeImpl

toString() - Method in class io.eventuate.tram.messaging.common.MessageImpl

TracingMessagingInterceptor - Class in io.eventuate.tram.spring.cloudsleuthintegration

tracingMessagingInterceptor(Tracing) - Method in class io.eventuate.tram.spring.cloudsleuthintegration.TramSpringCloudSleuthIntegrationConfiguration

TramConsumerBaseCommonConfiguration - Class in io.eventuate.tram.spring.consumer.common

TramConsumerBaseCommonConfiguration() - Constructor for class io.eventuate.tram.spring.consumer.common.TramConsumerBaseCommonConfiguration

TramConsumerBaseCommonFactory - Class in io.eventuate.tram.micronaut.consumer.common

TramConsumerBaseCommonFactory() - Constructor for class io.eventuate.tram.micronaut.consumer.common.TramConsumerBaseCommonFactory

TramConsumerCommonConfiguration - Class in io.eventuate.tram.spring.consumer.common

TramConsumerCommonConfiguration() - Constructor for class io.eventuate.tram.spring.consumer.common.TramConsumerCommonConfiguration

TramConsumerCommonFactory - Class in io.eventuate.tram.micronaut.consumer.common

TramConsumerCommonFactory() - Constructor for class io.eventuate.tram.micronaut.consumer.common.TramConsumerCommonFactory

TramConsumerJdbcAutoConfiguration - Class in io.eventuate.tram.spring.consumer.jdbc

TramConsumerJdbcAutoConfiguration() - Constructor for class io.eventuate.tram.spring.consumer.jdbc.TramConsumerJdbcAutoConfiguration

TramConsumerJdbcFactory - Class in io.eventuate.tram.micronaut.consumer.jdbc

TramConsumerJdbcFactory() - Constructor for class io.eventuate.tram.micronaut.consumer.jdbc.TramConsumerJdbcFactory

TramEventsCommonAutoConfiguration - Class in io.eventuate.tram.spring.events.common

TramEventsCommonAutoConfiguration() - Constructor for class io.eventuate.tram.spring.events.common.TramEventsCommonAutoConfiguration

TramEventsCommonFactory - Class in io.eventuate.tram.micronaut.events.common

TramEventsCommonFactory() - Constructor for class io.eventuate.tram.micronaut.events.common.TramEventsCommonFactory

TramEventsPublisherConfiguration - Class in io.eventuate.tram.spring.events.publisher

TramEventsPublisherConfiguration() - Constructor for class io.eventuate.tram.spring.events.publisher.TramEventsPublisherConfiguration

TramEventsPublisherFactory - Class in io.eventuate.tram.micronaut.events.publisher

TramEventsPublisherFactory() - Constructor for class io.eventuate.tram.micronaut.events.publisher.TramEventsPublisherFactory

TramEventSubscriberConfiguration - Class in io.eventuate.tram.spring.events.subscriber

TramEventSubscriberConfiguration() - Constructor for class io.eventuate.tram.spring.events.subscriber.TramEventSubscriberConfiguration

TramEventSubscriberFactory - Class in io.eventuate.tram.micronaut.events.subscriber

TramEventSubscriberFactory() - Constructor for class io.eventuate.tram.micronaut.events.subscriber.TramEventSubscriberFactory

TramInMemoryCommonConfiguration - Class in io.eventuate.tram.spring.inmemory

TramInMemoryCommonConfiguration() - Constructor for class io.eventuate.tram.spring.inmemory.TramInMemoryCommonConfiguration

TramInMemoryConfiguration - Class in io.eventuate.tram.spring.inmemory

TramInMemoryConfiguration() - Constructor for class io.eventuate.tram.spring.inmemory.TramInMemoryConfiguration

TramInMemoryFactory - Class in io.eventuate.tram.micronaut.inmemory

TramInMemoryFactory() - Constructor for class io.eventuate.tram.micronaut.inmemory.TramInMemoryFactory

TramIntegrationTestMySqlBinlogKafkaConfiguration - Class in io.eventuate.tram.integrationtest.common

TramIntegrationTestMySqlBinlogKafkaConfiguration() - Constructor for class io.eventuate.tram.integrationtest.common.TramIntegrationTestMySqlBinlogKafkaConfiguration

TramIntegrationTestMySqlBinlogRedisConfiguration - Class in io.eventuate.tram.integrationtest.common

TramIntegrationTestMySqlBinlogRedisConfiguration() - Constructor for class io.eventuate.tram.integrationtest.common.TramIntegrationTestMySqlBinlogRedisConfiguration

TramIntegrationTestPollingActiveMQConfiguration - Class in io.eventuate.tram.integrationtest.common

TramIntegrationTestPollingActiveMQConfiguration() - Constructor for class io.eventuate.tram.integrationtest.common.TramIntegrationTestPollingActiveMQConfiguration

TramIntegrationTestPostgresWalRabbitMQConfiguration - Class in io.eventuate.tram.integrationtest.common

TramIntegrationTestPostgresWalRabbitMQConfiguration() - Constructor for class io.eventuate.tram.integrationtest.common.TramIntegrationTestPostgresWalRabbitMQConfiguration

TramJdbcActiveMQConfiguration - Class in io.eventuate.tram.jdbcactivemq

TramJdbcActiveMQConfiguration() - Constructor for class io.eventuate.tram.jdbcactivemq.TramJdbcActiveMQConfiguration

TramJdbcKafkaConfiguration - Class in io.eventuate.tram.spring.jdbckafka

TramJdbcKafkaConfiguration() - Constructor for class io.eventuate.tram.spring.jdbckafka.TramJdbcKafkaConfiguration

TramJdbcRabbitMQConfiguration - Class in io.eventuate.tram.jdbcrabbitmq

TramJdbcRabbitMQConfiguration() - Constructor for class io.eventuate.tram.jdbcrabbitmq.TramJdbcRabbitMQConfiguration

TramJdbcRedisConfiguration - Class in io.eventuate.tram.jdbcredis

TramJdbcRedisConfiguration() - Constructor for class io.eventuate.tram.jdbcredis.TramJdbcRedisConfiguration

TramMessageProducerJdbcConfiguration - Class in io.eventuate.tram.spring.messaging.producer.jdbc

TramMessageProducerJdbcConfiguration() - Constructor for class io.eventuate.tram.spring.messaging.producer.jdbc.TramMessageProducerJdbcConfiguration

TramMessageProducerJdbcFactory - Class in io.eventuate.tram.micronaut.messaging.producer.jdbc

TramMessageProducerJdbcFactory() - Constructor for class io.eventuate.tram.micronaut.messaging.producer.jdbc.TramMessageProducerJdbcFactory

TramMessagingCommonAutoConfiguration - Class in io.eventuate.tram.spring.messaging.common

TramMessagingCommonAutoConfiguration() - Constructor for class io.eventuate.tram.spring.messaging.common.TramMessagingCommonAutoConfiguration

TramMessagingCommonFactory - Class in io.eventuate.tram.micronaut.messaging.common

TramMessagingCommonFactory() - Constructor for class io.eventuate.tram.micronaut.messaging.common.TramMessagingCommonFactory

TramMessagingCommonProducerConfiguration - Class in io.eventuate.tram.spring.messaging.producer.common

TramMessagingCommonProducerConfiguration() - Constructor for class io.eventuate.tram.spring.messaging.producer.common.TramMessagingCommonProducerConfiguration

TramMessagingCommonProducerFactory - Class in io.eventuate.tram.micronaut.messaging.producer.common

TramMessagingCommonProducerFactory() - Constructor for class io.eventuate.tram.micronaut.messaging.producer.common.TramMessagingCommonProducerFactory

TramNoopDuplicateMessageDetectorConfiguration - Class in io.eventuate.tram.spring.consumer.common

TramNoopDuplicateMessageDetectorConfiguration() - Constructor for class io.eventuate.tram.spring.consumer.common.TramNoopDuplicateMessageDetectorConfiguration

TramNoopDuplicateMessageDetectorFactory - Class in io.eventuate.tram.micronaut.consumer.common

TramNoopDuplicateMessageDetectorFactory() - Constructor for class io.eventuate.tram.micronaut.consumer.common.TramNoopDuplicateMessageDetectorFactory

TramSpringCloudSleuthIntegrationConfiguration - Class in io.eventuate.tram.spring.cloudsleuthintegration

TramSpringCloudSleuthIntegrationConfiguration() - Constructor for class io.eventuate.tram.spring.cloudsleuthintegration.TramSpringCloudSleuthIntegrationConfiguration

TransactionalNoopDuplicateMessageDetector - Class in io.eventuate.tram.consumer.jdbc

TransactionalNoopDuplicateMessageDetector(TransactionTemplate) - Constructor for class io.eventuate.tram.consumer.jdbc.TransactionalNoopDuplicateMessageDetector

TransactionalNoopDuplicateMessageDetectorConfiguration - Class in io.eventuate.tram.spring.consumer.jdbc

TransactionalNoopDuplicateMessageDetectorConfiguration() - Constructor for class io.eventuate.tram.spring.consumer.jdbc.TransactionalNoopDuplicateMessageDetectorConfiguration

TransactionalNoopDuplicateMessageDetectorFactory - Class in io.eventuate.tram.micronaut.consumer.jdbc

TransactionalNoopDuplicateMessageDetectorFactory() - Constructor for class io.eventuate.tram.micronaut.consumer.jdbc.TransactionalNoopDuplicateMessageDetectorFactory

transactionTemplate(PlatformTransactionManager) - Method in class io.eventuate.tram.micronaut.consumer.jdbc.TramConsumerJdbcFactory

transform(String) - Method in interface io.eventuate.tram.messaging.common.ChannelMapping

transform(String) - Method in class io.eventuate.tram.messaging.common.DefaultChannelMapping

U

unsubscribe() - Method in interface io.eventuate.tram.messaging.consumer.MessageSubscription

V

verify(Consumer<Message>) - Method in class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

verify(Runnable) - Method in class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

W

when() - Method in class io.eventuate.tram.testing.commands.CommandMessageHandlerUnitTestSupport

when() - Method in class io.eventuate.tram.testing.DomainEventHandlerUnitTestSupport

with(String, String) - Method in class io.eventuate.tram.messaging.common.DefaultChannelMapping.DefaultChannelMappingBuilder

withContext(Runnable) - Method in class io.eventuate.tram.inmemory.InMemoryMessageProducer

withContext(Runnable) - Method in interface io.eventuate.tram.messaging.producer.common.MessageProducerImplementation

withExtraHeaders(String, Map<String, String>) - Method in class io.eventuate.tram.messaging.producer.MessageBuilder

withHeader(String, String) - Method in class io.eventuate.tram.messaging.producer.MessageBuilder

withMessage(Message) - Static method in class io.eventuate.tram.messaging.producer.MessageBuilder

withPayload(String) - Static method in class io.eventuate.tram.messaging.producer.MessageBuilder

A B C D E F G H I M N O P R S T U V W