import { BaseEventConsumerEx, BaseEventProducer, DomainEventHandler, ExceptionHandler, KafkaConsumerConfig } from 'cm-libs-bootstrap';
import { EVSchema } from 'cm-schema-event';
export declare class LocationRecordEventProducer extends BaseEventProducer<EVSchema.EVLocationRecordEventParams> {
    private static self;
    private constructor();
    static init(topics: string[]): LocationRecordEventProducer;
    static get instance(): LocationRecordEventProducer;
    static term(): Promise<void>;
    static plugin(options: {
        topics: string[];
    }): {
        serverWillStart(): Promise<{
            serverWillStop(): Promise<void>;
        }>;
    };
}
export declare class LocationRecordEventConsumer extends BaseEventConsumerEx<EVSchema.EVLocationRecordEventParams, unknown> {
    private static self;
    private constructor();
    static init(config: KafkaConsumerConfig): LocationRecordEventConsumer;
    static get instance(): LocationRecordEventConsumer;
    static term(): Promise<void>;
    static plugin(options: KafkaConsumerConfig & {
        subscribeFunction: DomainEventHandler<EVSchema.EVLocationRecordEventParams, unknown>;
        errorHandlerFunction: ExceptionHandler<EVSchema.EVLocationRecordEventParams, unknown>;
    }): {
        serverWillStart(): Promise<{
            drainServer(): Promise<void>;
        }>;
    };
}
export declare class TerminalConfigRecordEventProducer extends BaseEventProducer<EVSchema.EVTerminalConfigRecordEventParams> {
    private static self;
    private constructor();
    static init(topics: string[]): TerminalConfigRecordEventProducer;
    static get instance(): TerminalConfigRecordEventProducer;
    static term(): Promise<void>;
    static plugin(options: {
        topics: string[];
    }): {
        serverWillStart(): Promise<{
            serverWillStop(): Promise<void>;
        }>;
    };
}
export declare class TerminalConfigRecordEventConsumer extends BaseEventConsumerEx<EVSchema.EVTerminalConfigRecordEventParams, unknown> {
    private static self;
    private constructor();
    static init(config: KafkaConsumerConfig): TerminalConfigRecordEventConsumer;
    static get instance(): TerminalConfigRecordEventConsumer;
    static term(): Promise<void>;
    static plugin(options: KafkaConsumerConfig & {
        subscribeFunction: DomainEventHandler<EVSchema.EVTerminalConfigRecordEventParams, unknown>;
        errorHandlerFunction: ExceptionHandler<EVSchema.EVTerminalConfigRecordEventParams, unknown>;
    }): {
        serverWillStart(): Promise<{
            drainServer(): Promise<void>;
        }>;
    };
}