import { ITask, KafkaConfiguration, RedisConfiguration, SQSConfiguration, DummyConfiguration, Callback, IProducer, IRegistry, MessageRoutingOptions, Configuration, PayloadT } from '../common';
import { TaskOptions } from '../types/task-options';
declare class Task<T extends PayloadT = Record<string, any>, R = any, E extends Configuration['engine'] = any> implements ITask<T, R> {
    config: KafkaConfiguration | RedisConfiguration | SQSConfiguration | DummyConfiguration;
    registry: IRegistry;
    subscribe: Callback<T, R>;
    producer: IProducer;
    name: string;
    topic: string;
    options: TaskOptions;
    constructor(config: KafkaConfiguration | RedisConfiguration | SQSConfiguration | DummyConfiguration, registry: IRegistry, producer: IProducer, name: string, topic: string, subscribe: Callback<T, R>, options?: TaskOptions);
    publish(payload: T | T[], options?: MessageRoutingOptions[E]): Promise<void>;
}
export default Task;