import { Message, Stan } from 'node-nats-streaming';
import { BaseEvent } from "../index";
export default abstract class BaseListener<T extends BaseEvent> {
    abstract subject: T["subject"];
    abstract durableName: string;
    abstract queueGroupName: string;
    abstract onMessage(data: T["data"], msg: Message): void;
    protected client: Stan;
    protected ackWait: number;
    constructor(client: Stan);
    subscriptionOptions(): import("node-nats-streaming").SubscriptionOptions;
    listen(): void;
    parseMessage(msg: Message): any;
}