Package io.debezium.heartbeat

Class DatabaseHeartbeatFactory

java.lang.Object

io.debezium.heartbeat.DatabaseHeartbeatFactory

All Implemented Interfaces:

DebeziumHeartbeatFactory

public class DatabaseHeartbeatFactory
extends Object
implements DebeziumHeartbeatFactory

Constructor Summary

Constructors

Constructor	Description
DatabaseHeartbeatFactory()

Method Summary

Modifier and Type	Method	Description
Optional<Heartbeat>	getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.heartbeat.DebeziumHeartbeatFactory

getScheduledHeartbeat

Constructor Details

DatabaseHeartbeatFactory

public DatabaseHeartbeatFactory()

Method Details

getHeartbeat

public Optional<Heartbeat> getHeartbeat(CommonConnectorConfig connectorConfig,
 HeartbeatConnectionProvider connectionProvider,
 HeartbeatErrorHandler errorHandler,
 ChangeEventQueue<DataChangeEvent> queue)

Specified by:

getHeartbeat in interface DebeziumHeartbeatFactory