import { FastifyInstance } from 'fastify';
import { QueueServiceInterface, MessageHandler } from './types';
export declare class QueueService implements QueueServiceInterface {
    private subscriber;
    private publisher;
    private fastify;
    constructor(fastify: FastifyInstance, messageHandler: MessageHandler);
    startSubscription(): Promise<void>;
    publishMessage(message: any, routingKey?: string): Promise<boolean>;
    publishMessageWithOptions(options: any): Promise<boolean>;
    closeConnection(): Promise<void>;
    isSubscriptionActive(): boolean;
    publishBatch(messages: any[], routingKey?: string): Promise<{
        success: number;
        failed: number;
    }>;
}
export declare const createQueueService: (fastify: FastifyInstance, messageHandler: MessageHandler) => QueueService;
//# sourceMappingURL=queue-service.d.ts.map