Page History

/** Consumer of WAL records */
public interface CDCConsumer {
    /**
     * @return Consumer ID.
     */
    String id();

    /**
     * Initialize this consumer.
     *
     * @param configuration Ignite configuration.
     */
    void start(IgniteConfiguration configuration, IgniteLogger log);

    /**
     * @param record WAL record.
     * @param <T> Record type.
	 * @return {@code True} if state of the consumption should be saved.
     */
    <T extends WALRecord> booolean onRecord(T record);

    /**
     * Stops this consumer.
     * This methods can be invoked only after {@link #start(IgniteConfiguration, IgniteLogger)}.
     */
    void stop();
}