| 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(message);
|
| 11 | }
|