import { RotifMessage } from './types.js';
export type MiddlewareContext = {
    message: RotifMessage;
    next: () => Promise<void>;
};
export type Middleware = {
    beforePublish?: (channel: string, payload: any, options?: any) => void | Promise<void>;
    afterPublish?: (channel: string, payload: any, id: string[] | string | null, options?: any) => void | Promise<void>;
    beforeProcess?: (msg: RotifMessage) => void | Promise<void>;
    afterProcess?: (msg: RotifMessage) => void | Promise<void>;
    onError?: (msg: RotifMessage, error: Error) => void | Promise<void>;
};
export declare class MiddlewareManager {
    private middleware;
    use(mw: Middleware): void;
    runBeforePublish(channel: string, payload: any, options?: any): Promise<void>;
    runAfterPublish(channel: string, payload: any, id: string[] | string | null, options?: any): Promise<void>;
    runBeforeProcess(msg: RotifMessage): Promise<void>;
    runAfterProcess(msg: RotifMessage): Promise<void>;
    runOnError(msg: RotifMessage, err: Error): Promise<void>;
}
//# sourceMappingURL=middleware.d.ts.map