import { Channel, RedisAdapter } from "@myunisoft/redis";
import type { DistributedEventMessage, GenericEvent, IncomerChannelMessages } from "../types/index.js";
export interface IncomerChannelHandlerOptions<T extends GenericEvent> {
    redis: RedisAdapter;
    subscriber: RedisAdapter;
    channels?: Map<string, Channel<DistributedEventMessage<T>>>;
}
export interface SetChannelOptions {
    uuid: string;
    subscribe?: boolean;
}
export type ChannelMessages<T extends GenericEvent> = Channel<IncomerChannelMessages<T>["DispatcherMessages"]>;
export declare class IncomerChannelHandler<T extends GenericEvent = GenericEvent> {
    #private;
    channels: Map<string, ChannelMessages<T>>;
    constructor(options: IncomerChannelHandlerOptions<T>);
    set(options: SetChannelOptions): Channel<Record<string, any>, null>;
    get(uuid: string): ChannelMessages<T> | null;
    remove(uuid: string): Promise<void>;
}
//# sourceMappingURL=incomer-channel.class.d.ts.map