Package io.outbox.spring.boot

Class OutboxAutoConfiguration

java.lang.Object

io.outbox.spring.boot.OutboxAutoConfiguration

@AutoConfiguration(after=org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration.class)
@ConditionalOnClass(Outbox.class)
@ConditionalOnBean(javax.sql.DataSource.class)
@EnableConfigurationProperties(OutboxProperties.class)
public class OutboxAutoConfiguration
extends Object

Auto-configuration for the outbox framework.

Wires up an Outbox composite from a DataSource and OutboxProperties. Supports single-node, multi-node, ordered, and writer-only modes.

See Also:

• OutboxProperties
• OutboxMicrometerAutoConfiguration

Constructor Summary

Constructors

Constructor	Description
OutboxAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
DataSourceConnectionProvider	connectionProvider(DataSource dataSource)
JacksonJsonCodec	jacksonJsonCodec(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
DefaultListenerRegistry	listenerRegistry()
Outbox	outbox(OutboxProperties props, ConnectionProvider connectionProvider, TxContext txContext, AbstractJdbcOutboxStore outboxStore, DefaultListenerRegistry listenerRegistry, org.springframework.beans.factory.ObjectProvider<MetricsExporter> metricsProvider, org.springframework.beans.factory.ObjectProvider<EventInterceptor> interceptorProvider)
OutboxLifecycle	outboxLifecycle(Outbox outbox)
OutboxListenerRegistrar	outboxListenerRegistrar(org.springframework.beans.factory.ListableBeanFactory beanFactory, DefaultListenerRegistry listenerRegistry)
AbstractJdbcOutboxStore	outboxStore(DataSource dataSource, OutboxProperties props)
OutboxWriter	outboxWriter(Outbox outbox)
SpringTxContext	txContext(DataSource dataSource)

Methods inherited from class java.lang.Object

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

Constructor Details

OutboxAutoConfiguration

public OutboxAutoConfiguration()

Method Details

jacksonJsonCodec

@Bean
@ConditionalOnMissingBean(JsonCodec.class)
@ConditionalOnBean(com.fasterxml.jackson.databind.ObjectMapper.class)
public JacksonJsonCodec jacksonJsonCodec(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

outboxStore

@Bean
@ConditionalOnMissingBean
public AbstractJdbcOutboxStore outboxStore(DataSource dataSource,
 OutboxProperties props)

connectionProvider

@Bean
@ConditionalOnMissingBean(ConnectionProvider.class)
public DataSourceConnectionProvider connectionProvider(DataSource dataSource)

txContext

@Bean
@ConditionalOnMissingBean(TxContext.class)
public SpringTxContext txContext(DataSource dataSource)

listenerRegistry

@Bean
@ConditionalOnMissingBean
public DefaultListenerRegistry listenerRegistry()

outboxListenerRegistrar

@Bean
@ConditionalOnMissingBean
public OutboxListenerRegistrar outboxListenerRegistrar(org.springframework.beans.factory.ListableBeanFactory beanFactory,
 DefaultListenerRegistry listenerRegistry)

outbox

@Bean(destroyMethod="close")
@ConditionalOnMissingBean
public Outbox outbox(OutboxProperties props,
 ConnectionProvider connectionProvider,
 TxContext txContext,
 AbstractJdbcOutboxStore outboxStore,
 DefaultListenerRegistry listenerRegistry,
 org.springframework.beans.factory.ObjectProvider<MetricsExporter> metricsProvider,
 org.springframework.beans.factory.ObjectProvider<EventInterceptor> interceptorProvider)

outboxWriter

@Bean
@ConditionalOnMissingBean
public OutboxWriter outboxWriter(Outbox outbox)

outboxLifecycle

@Bean
@ConditionalOnMissingBean
public OutboxLifecycle outboxLifecycle(Outbox outbox)