import { Source, SourceCallback, SourceOptions } from '@neoskop/paperboy';
export declare class MagnoliaSource implements Source {
    private readonly options;
    private readonly callback;
    private readonly generationLock;
    constructor(options: SourceOptions, callback: SourceCallback);
    generate(): Promise<void>;
    start(): Promise<void>;
    private retryConnection();
    private consumeMessage(message);
}