import { PubsubMessageMeta, PubsubService, SubscriptionOptions } from '@erento/nestjs-module-google-pubsub';
import { Logger } from '../logger/logger';
import { BasicAppService } from '../services/basic-app.service';
export declare abstract class PubSubMessageSubscriber<TMsgBody, TAppSvc extends BasicAppService> {
    protected readonly appService: TAppSvc;
    protected readonly logger: Logger;
    protected readonly pubsubService: PubsubService;
    protected readonly cronjobName: string | undefined;
    protected readonly disableSubscription: boolean;
    protected readonly delayAfterStartup: number;
    protected readonly skipDeadline: number;
    private topicName;
    private pubsubSubscription;
    protected constructor(appService: TAppSvc, logger: Logger, pubsubService: PubsubService, cronjobName?: string | undefined, disableSubscription?: boolean, delayAfterStartup?: number, skipDeadline?: number);
    protected subscribeToPubSub(subscriptionName: string, topicName: string, options?: SubscriptionOptions | undefined, cronJobName?: string | undefined, encrypted?: boolean): void;
    protected unsubscribeFromPubsub(): void;
    private onMessageReceived;
    private onMessageError;
    private contextify;
    abstract handleRequest(parsedBody: TMsgBody, meta: PubsubMessageMeta): Promise<void>;
}