import type { RedisClient } from '../redis';
import { IMessageChannel, MessageChannel } from './message-channel';
import type { QueueMessage, SubscribeQueueCallback } from 'suanpan-mq';
export interface SubscribeCallback<M> extends SubscribeQueueCallback {
    (messages: M): Promise<void>;
}
export interface ISubscribableChannel<T> extends IMessageChannel<T> {
    subscribe<M extends QueueMessage>(handler: SubscribeCallback<M>, group?: string, consumer?: string): Promise<void>;
}
export declare class SubscribableChannel<T> extends MessageChannel<T> implements ISubscribableChannel<T> {
    private recieiveQueue;
    constructor(conn: RedisClient, recieiveQueue: string, sendQueue: string);
    subscribe<M extends QueueMessage>(handler: SubscribeCallback<M>, group?: string, consumer?: string): Promise<void>;
}