import RedisSMQ from 'rsmq';
import { IProducer, IRegistry, RedisConfiguration } from '../common';
import { Logger } from '../lib/logger';
import { BaseProducer } from './base';
declare class RedisProducer extends BaseProducer implements IProducer {
    config: RedisConfiguration;
    registry: IRegistry;
    logger: Logger;
    producer: RedisSMQ;
    constructor(config: RedisConfiguration, registry: IRegistry, logger?: Logger);
    initialize(topic: string): Promise<void>;
    getPayload(msg: any, topic: string): any;
    send<T = any>(topic: string, payload: T): Promise<void>;
}
export default RedisProducer;