/// <reference types="node" />
import { IMessagingService, GenericMessage } from "@connext/types";
import { EventEmitter } from "events";
export declare type MessagingLimit = {
    to: string;
    limit: number;
};
export declare type MessagingLimitAndCount = MessagingLimit & {
    count: number;
};
export declare class MemoryMessagingServiceWithLimits implements IMessagingService {
    eventEmitter: EventEmitter;
    private limit;
    private protocol?;
    private readonly name;
    private connected;
    private messageCount;
    private logger;
    private isSend;
    constructor(eventEmitter?: EventEmitter, limit?: number, protocol?: "setup" | "install" | "propose" | "sync" | "takeAction" | "uninstall" | undefined, sendOrReceive?: "send" | "receive", name?: string);
    send(to: string, msg: GenericMessage): Promise<void>;
    onReceive(address: string, callback: (msg: GenericMessage) => void): Promise<void>;
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    clearLimits(): void;
    flush(): Promise<void>;
    publish(subject: string, data: any): Promise<void>;
    request(subject: string, timeout: number, data: object, callback?: (response: any) => any): Promise<void>;
    subscribe(subject: string, callback: (msg: GenericMessage) => void): Promise<void>;
    unsubscribe(subject: string): Promise<void>;
}
//# sourceMappingURL=memory-messaging-service-limits.d.ts.map