Class StoppableChangeEventSourceContext

  • All Implemented Interfaces:
    io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext

    public class StoppableChangeEventSourceContext
    extends Object
    implements io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext
    A change event source context that can stop the running source by invoking stopChangeEventSource().
    • Constructor Detail

      • StoppableChangeEventSourceContext

        public StoppableChangeEventSourceContext()
    • Method Detail

      • startChangeEventSource

        public void startChangeEventSource()
      • stopChangeEventSource

        public void stopChangeEventSource()
      • isRunning

        public boolean isRunning()
        Specified by:
        isRunning in interface io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext