Package io.outbox.demo.spring

Class OutboxConfiguration

java.lang.Object

io.outbox.demo.spring.OutboxConfiguration

@Configuration
public class OutboxConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
OutboxConfiguration()

Method Summary

Modifier and Type	Method	Description
DataSourceConnectionProvider	connectionProvider(DataSource dataSource)
OutboxDispatcher	dispatcher(DataSourceConnectionProvider connectionProvider, AbstractJdbcOutboxStore outboxStore, ListenerRegistry listenerRegistry)
ListenerRegistry	listenerRegistry()
void	onReady(org.springframework.boot.context.event.ApplicationReadyEvent event)
OutboxPoller	outboxPoller(DataSourceConnectionProvider connectionProvider, AbstractJdbcOutboxStore outboxStore, OutboxDispatcher dispatcher)
AbstractJdbcOutboxStore	outboxStore(DataSource dataSource)
OutboxWriter	outboxWriter(TxContext txContext, AbstractJdbcOutboxStore outboxStore, OutboxDispatcher dispatcher)
TxContext	txContext(DataSource dataSource)

Methods inherited from class java.lang.Object

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

Constructor Details

OutboxConfiguration

public OutboxConfiguration()

Method Details

outboxStore

@Bean
public AbstractJdbcOutboxStore outboxStore(DataSource dataSource)

connectionProvider

@Bean
public DataSourceConnectionProvider connectionProvider(DataSource dataSource)

txContext

@Bean
public TxContext txContext(DataSource dataSource)

listenerRegistry

@Bean
public ListenerRegistry listenerRegistry()

dispatcher

@Bean(destroyMethod="close")
public OutboxDispatcher dispatcher(DataSourceConnectionProvider connectionProvider,
 AbstractJdbcOutboxStore outboxStore,
 ListenerRegistry listenerRegistry)

outboxPoller

@Bean(destroyMethod="close")
public OutboxPoller outboxPoller(DataSourceConnectionProvider connectionProvider,
 AbstractJdbcOutboxStore outboxStore,
 OutboxDispatcher dispatcher)

onReady

@EventListener(org.springframework.boot.context.event.ApplicationReadyEvent.class)
public void onReady(org.springframework.boot.context.event.ApplicationReadyEvent event)

outboxWriter

@Bean
public OutboxWriter outboxWriter(TxContext txContext,
 AbstractJdbcOutboxStore outboxStore,
 OutboxDispatcher dispatcher)