Package dev.henneberger.vertx.sqlserver.replication

Class SqlServerLogicalReplicationStream

java.lang.Object

dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

dev.henneberger.vertx.sqlserver.replication.SqlServerLogicalReplicationStream

All Implemented Interfaces:

dev.henneberger.vertx.replication.core.ReplicationStream<SqlServerChangeEvent>, AutoCloseable

public class SqlServerLogicalReplicationStream
extends dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

Constructor Summary

Constructors

Constructor	Description
SqlServerLogicalReplicationStream(io.vertx.core.Vertx vertx, SqlServerReplicationOptions options)

Method Summary

Modifier and Type	Method	Description
dev.henneberger.vertx.replication.core.AdapterMode	adapterMode()
protected boolean	autoStart()
protected dev.henneberger.vertx.replication.core.LsnStore	checkpointStore()
protected void	logStreamFailure(Throwable error)
protected int	maxConcurrentDispatch()
protected boolean	preflightEnabled()
protected dev.henneberger.vertx.replication.core.RetryPolicy	retryPolicy()
protected dev.henneberger.vertx.replication.core.PreflightReport	runPreflightChecks()
protected void	runSession(long attempt)
dev.henneberger.vertx.replication.core.SubscriptionRegistration	startAndSubscribe(SqlServerChangeFilter filter, io.vertx.core.Handler<SqlServerChangeEvent> eventHandler, io.vertx.core.Handler<Throwable> errorHandler)
protected String	streamName()
SqlServerChangeSubscription	subscribe(dev.henneberger.vertx.replication.core.ChangeFilter<SqlServerChangeEvent> filter, dev.henneberger.vertx.replication.core.ChangeConsumer<SqlServerChangeEvent> eventConsumer, io.vertx.core.Handler<Throwable> errorHandler)
SqlServerChangeSubscription	subscribe(SqlServerChangeFilter filter, SqlServerChangeConsumer eventConsumer, io.vertx.core.Handler<Throwable> errorHandler)

Methods inherited from class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream

addMetricsListener, close, completeStart, dispatchAndAwait, emitEventMetric, emitLsnCommitted, emitParseFailure, loadCheckpoint, notifyError, onCloseResources, onStateChange, preflight, registerSubscription, saveCheckpoint, shouldRun, sleepInterruptibly, start, startAndSubscribe, state, transition, vertx

Methods inherited from class java.lang.Object

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

Constructor Details

SqlServerLogicalReplicationStream

public SqlServerLogicalReplicationStream(io.vertx.core.Vertx vertx,
 SqlServerReplicationOptions options)

Method Details

subscribe

public SqlServerChangeSubscription subscribe(dev.henneberger.vertx.replication.core.ChangeFilter<SqlServerChangeEvent> filter,
 dev.henneberger.vertx.replication.core.ChangeConsumer<SqlServerChangeEvent> eventConsumer,
 io.vertx.core.Handler<Throwable> errorHandler)

Specified by:

subscribe in interface dev.henneberger.vertx.replication.core.ReplicationStream<SqlServerChangeEvent>

Overrides:

subscribe in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

subscribe

public SqlServerChangeSubscription subscribe(SqlServerChangeFilter filter,
 SqlServerChangeConsumer eventConsumer,
 io.vertx.core.Handler<Throwable> errorHandler)

startAndSubscribe

public dev.henneberger.vertx.replication.core.SubscriptionRegistration startAndSubscribe(SqlServerChangeFilter filter,
 io.vertx.core.Handler<SqlServerChangeEvent> eventHandler,
 io.vertx.core.Handler<Throwable> errorHandler)

adapterMode

public dev.henneberger.vertx.replication.core.AdapterMode adapterMode()

streamName

protected String streamName()

Specified by:

streamName in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

maxConcurrentDispatch

protected int maxConcurrentDispatch()

Specified by:

maxConcurrentDispatch in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

preflightEnabled

protected boolean preflightEnabled()

Specified by:

preflightEnabled in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

autoStart

protected boolean autoStart()

Specified by:

autoStart in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

retryPolicy

protected dev.henneberger.vertx.replication.core.RetryPolicy retryPolicy()

Specified by:

retryPolicy in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

checkpointStore

protected dev.henneberger.vertx.replication.core.LsnStore checkpointStore()

Specified by:

checkpointStore in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

runPreflightChecks

protected dev.henneberger.vertx.replication.core.PreflightReport runPreflightChecks()

Specified by:

runPreflightChecks in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

runSession

protected void runSession(long attempt)
                   throws Exception

Specified by:

runSession in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>

Throws:

Exception

logStreamFailure

protected void logStreamFailure(Throwable error)

Specified by:

logStreamFailure in class dev.henneberger.vertx.replication.core.AbstractWorkerReplicationStream<SqlServerChangeEvent>