io.eventuate.local.java.spring.common.jdbckafkastore

Class EventuateLocalConfiguration

java.lang.Object

io.eventuate.local.java.spring.common.jdbckafkastore.EventuateLocalConfiguration

@Configuration
 @EnableTransactionManagement
 @Import(value={EventuateCommonConfiguration.class,io.eventuate.common.spring.jdbc.EventuateCommonJdbcOperationsConfiguration.class,io.eventuate.messaging.kafka.spring.basic.consumer.EventuateKafkaConsumerSpringConfigurationPropertiesConfiguration.class,io.eventuate.messaging.kafka.spring.common.EventuateKafkaPropertiesConfiguration.class,io.eventuate.messaging.kafka.spring.basic.consumer.EventuateKafkaConsumerSpringConfigurationPropertiesConfiguration.class,io.eventuate.messaging.kafka.spring.consumer.KafkaConsumerFactoryConfiguration.class})
public class EventuateLocalConfiguration
extends java.lang.Object

Defines the Spring beans for the JDBC-based aggregate store

Constructor Summary

Constructors

Constructor and Description
EventuateLocalConfiguration()

Method Summary

Modifier and Type	Method and Description
io.eventuate.local.java.jdbc.jdbckafkastore.EventuateKafkaAggregateSubscriptions	aggregateEvents(io.eventuate.messaging.kafka.common.EventuateKafkaConfigurationProperties eventuateLocalAggregateStoreConfiguration, io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumerConfigurationProperties eventuateKafkaConsumerConfigurationProperties, io.eventuate.messaging.kafka.basic.consumer.KafkaConsumerFactory kafkaConsumerFactory)
io.eventuate.javaclient.commonimpl.AggregateCrud	asyncAggregateCrud(io.eventuate.javaclient.commonimpl.sync.AggregateCrud aggregateCrud)
EventuateJdbcAccess	eventuateJdbcAccess(io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate, io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor, io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations, io.eventuate.common.jdbc.EventuateSchema eventuateSchema)
io.eventuate.local.java.jdbc.jdbckafkastore.EventuateLocalAggregateCrud	eventuateLocalAggregateCrud(org.springframework.transaction.support.TransactionTemplate transactionTemplate, EventuateJdbcAccess eventuateJdbcAccess)
io.eventuate.javaclient.commonimpl.sync.AggregateEvents	syncAggregateEvents(io.eventuate.javaclient.commonimpl.adapters.AsyncToSyncTimeoutOptions timeoutOptions, io.eventuate.javaclient.commonimpl.AggregateEvents aggregateEvents)
org.springframework.transaction.support.TransactionTemplate	transactionTemplate(org.springframework.transaction.PlatformTransactionManager platformTransactionManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventuateLocalConfiguration

public EventuateLocalConfiguration()

Method Detail

eventuateJdbcAccess

@Bean
public EventuateJdbcAccess eventuateJdbcAccess(io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate,
                                                     io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor,
                                                     io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations,
                                                     io.eventuate.common.jdbc.EventuateSchema eventuateSchema)

eventuateLocalAggregateCrud

@Bean
public io.eventuate.local.java.jdbc.jdbckafkastore.EventuateLocalAggregateCrud eventuateLocalAggregateCrud(org.springframework.transaction.support.TransactionTemplate transactionTemplate,
                                                                                                                 EventuateJdbcAccess eventuateJdbcAccess)

asyncAggregateCrud

@Bean
public io.eventuate.javaclient.commonimpl.AggregateCrud asyncAggregateCrud(io.eventuate.javaclient.commonimpl.sync.AggregateCrud aggregateCrud)

aggregateEvents

@Bean
public io.eventuate.local.java.jdbc.jdbckafkastore.EventuateKafkaAggregateSubscriptions aggregateEvents(io.eventuate.messaging.kafka.common.EventuateKafkaConfigurationProperties eventuateLocalAggregateStoreConfiguration,
                                                                                                              io.eventuate.messaging.kafka.basic.consumer.EventuateKafkaConsumerConfigurationProperties eventuateKafkaConsumerConfigurationProperties,
                                                                                                              io.eventuate.messaging.kafka.basic.consumer.KafkaConsumerFactory kafkaConsumerFactory)

syncAggregateEvents

@Bean
public io.eventuate.javaclient.commonimpl.sync.AggregateEvents syncAggregateEvents(@Autowired(required=false)
                                                                                         io.eventuate.javaclient.commonimpl.adapters.AsyncToSyncTimeoutOptions timeoutOptions,
                                                                                         io.eventuate.javaclient.commonimpl.AggregateEvents aggregateEvents)

transactionTemplate

@Bean
public org.springframework.transaction.support.TransactionTemplate transactionTemplate(org.springframework.transaction.PlatformTransactionManager platformTransactionManager)