import Redis from 'ioredis';
import { Observable } from 'rxjs';
export interface RedisMQOptions {
    startTime?: number | string;
    endTime?: number | string;
    batchSize?: number;
    autoReplay?: boolean;
    setName?: string;
}
export interface RedisMQMessage {
    data: any;
    sqNr: string;
}
export interface RemoveOptions {
    channel: string;
    startTime?: number | string;
    endTime?: number | string;
}
export interface ReplayOptions {
    setName: string;
    startTime?: number | string;
    endTime?: number | string;
    batchSize?: number;
}
export interface SubscribeOptions {
    startTime?: number | string;
    autoReplay?: boolean;
}
export declare class RedisMQ {
    private pub;
    private sub;
    constructor(redisConfig?: any);
    on(event: string, listener: (...args: any[]) => void): Redis;
    remove({ channel, startTime, endTime }: RemoveOptions): Promise<number>;
    close(): void;
    del(channel: string): Promise<number>;
    keys(pattern: string): Promise<string[]>;
    replay(options: ReplayOptions): Observable<any>;
    subscribe(topic: string, options?: SubscribeOptions): Observable<any>;
    send(setName: string, data: any, persistant?: boolean): Promise<RedisMQMessage>;
    get(setName: string): Promise<any>;
    set(setName: string, data: any): Promise<string>;
    hget(setName: string, field: string): Promise<any>;
    hgetall(setName: string): Promise<{
        [key: string]: string;
    }>;
    hset(setName: string, field: string, data: any): Promise<number>;
}