Package su.onno.cluster.pg

Class OnnoClusterAutoConfiguration

java.lang.Object

su.onno.cluster.pg.OnnoClusterAutoConfiguration

@AutoConfiguration(after=org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration.class,
                   before=OnnoAutoConfiguration.class)
@ConditionalOnClass(name="org.postgresql.PGConnection")
@ConditionalOnBean(javax.sql.DataSource.class)
@ConditionalOnProperty(prefix="onno.cluster",
                       name="enabled",
                       havingValue="true",
                       matchIfMissing=true)
@EnableConfigurationProperties(OnnoClusterProperties.class)
public class OnnoClusterAutoConfiguration
extends Object

Wires the Postgres LISTEN/NOTIFY ClusterEventBus default.

Ordered before OnnoAutoConfiguration so its @ConditionalOnMissingBean bus registers ahead of that module's no-op fallback. It contributes a bus only when the PostgreSQL JDBC driver is present and the live datasource is actually Postgres (detected via SqlDialect); on H2 (dev/test) it returns a NoOpClusterEventBus, so the framework's single-node behaviour is preserved. An application's own ClusterEventBus bean (e.g. Kafka/Redis) wins over both via @ConditionalOnMissingBean.

Constructor Summary

Constructors

Constructor	Description
OnnoClusterAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
ClusterEventBus	onnoClusterEventBus(DataSource dataSource, com.fasterxml.jackson.databind.ObjectMapper objectMapper, OnnoClusterProperties properties)

Methods inherited from class java.lang.Object

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

Constructor Details

OnnoClusterAutoConfiguration

public OnnoClusterAutoConfiguration()

Method Details

onnoClusterEventBus

@Bean
@ConditionalOnMissingBean(ClusterEventBus.class)
public ClusterEventBus onnoClusterEventBus(DataSource dataSource,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 OnnoClusterProperties properties)