Package com.zendesk.maxwell.replication

Class BinlogConnectorLivenessMonitor

java.lang.Object

com.zendesk.maxwell.replication.BinlogConnectorLivenessMonitor

All Implemented Interfaces:

com.github.shyiko.mysql.binlog.BinaryLogClient.EventListener, com.github.shyiko.mysql.binlog.BinaryLogClient.LifecycleListener

public class BinlogConnectorLivenessMonitor
extends Object
implements com.github.shyiko.mysql.binlog.BinaryLogClient.EventListener, com.github.shyiko.mysql.binlog.BinaryLogClient.LifecycleListener

Constructor Summary

Constructors

Constructor	Description
BinlogConnectorLivenessMonitor(com.github.shyiko.mysql.binlog.BinaryLogClient client)

Method Summary

Modifier and Type	Method	Description
boolean	isAlive()
void	onCommunicationFailure(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient, Exception e)
void	onConnect(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient)
void	onDisconnect(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient)
void	onEvent(com.github.shyiko.mysql.binlog.event.Event event)
void	onEventDeserializationFailure(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient, Exception e)

Methods inherited from class java.lang.Object

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

Constructor Detail

BinlogConnectorLivenessMonitor

public BinlogConnectorLivenessMonitor(com.github.shyiko.mysql.binlog.BinaryLogClient client)

Method Detail

isAlive

public boolean isAlive()

onEvent

public void onEvent(com.github.shyiko.mysql.binlog.event.Event event)

Specified by:

onEvent in interface com.github.shyiko.mysql.binlog.BinaryLogClient.EventListener

onConnect

public void onConnect(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient)

Specified by:

onConnect in interface com.github.shyiko.mysql.binlog.BinaryLogClient.LifecycleListener

onCommunicationFailure

public void onCommunicationFailure(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient,
                                   Exception e)

Specified by:

onCommunicationFailure in interface com.github.shyiko.mysql.binlog.BinaryLogClient.LifecycleListener

onEventDeserializationFailure

public void onEventDeserializationFailure(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient,
                                          Exception e)

Specified by:

onEventDeserializationFailure in interface com.github.shyiko.mysql.binlog.BinaryLogClient.LifecycleListener

onDisconnect

public void onDisconnect(com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient)

Specified by:

onDisconnect in interface com.github.shyiko.mysql.binlog.BinaryLogClient.LifecycleListener