/// <reference types="node" />
import { EventBus } from "./event-bus";
import { GracefulShutdownOptions } from "./consumer";
export interface Drainable {
    gracefulShutdown?(options?: GracefulShutdownOptions): Promise<void>;
    disconnect?(): Promise<void>;
    close?(): Promise<void>;
}
export interface RegisterGracefulShutdownOptions extends GracefulShutdownOptions {
    signals?: NodeJS.Signals[];
    onComplete?: () => void;
    onError?: (error: Error, resource: Drainable) => void;
    exitProcess?: boolean;
}
export declare function registerGracefulShutdown(resources: Drainable | Drainable[], options?: RegisterGracefulShutdownOptions): () => void;
export declare function supportsConsumerScenarios<M, H, E>(bus: EventBus<M, H, E>): bus is EventBus<M, H, E> & Required<Pick<EventBus<M, H, E>, "consume">>;