stop running

distribute to annotation listener interfaces @param destination destination @param schemaName schema @param tableName table name @param eventType eve

distribute to listener interfaces @param eventType eventType @param rowData rowData

to distribute the message to special event and let the event listeners to handle it @param message canal message

get the filters predicate @param destination destination @param schemaName schema @param tableName table name @param eventType event type @return pre

get the config @return config

get the ignore eventType list @return eventType list

get the args @param method method @param eventType event type @param rowData row data @return args which will be used by invoking the annotation meth

init listeners

@param connector connector @param config config @param listeners listeners @param annoListeners annoListeners @return MessageTransponder

run when event was fired @param eventType eventType @param rowData rowData

To initialize the canal connector @param connector CanalConnector @param config config

process the ddl event @param rowChange rowChange

open the canal client to get the config and connect to the canal server (1 : 1 or 1 : n) and then transfer the event to the special listener

stop the client

get the filters predicate @param destination destination @param schemaName schema @param tableName table name @param eventType event type @return pre

is running @return yes or no

fired on delete event @param rowData rowData

fired on insert event @param rowData rowData

fired on update event @param rowData rowData