1 | import { Source, SourceCallback, SourceOptions } from "@neoskop/paperboy";
|
2 | export declare class MagnoliaSource implements Source {
|
3 | private readonly options;
|
4 | private readonly callback;
|
5 | private readonly generationLock;
|
6 | constructor(options: SourceOptions, callback: SourceCallback);
|
7 | generate(): Promise<void>;
|
8 | start(): Promise<void>;
|
9 | private retryConnection;
|
10 | private consumeMessage;
|
11 | }
|