import { MatchSpec } from "../match"; import Message from "../message"; import * as pubsub from "../pubsub"; import Hub from "../hub"; export interface QueueOptions { capacity?: number; pattern?: string | string[]; persistent?: boolean; } export declare class Queue extends pubsub.BaseSource implements pubsub.Initializable { name: string; capacity: number; private _queue; private _matcher; private _storage; private _options; constructor(name: string, options?: QueueOptions); init(hub: Hub): Promise; send(message: Message): void; bind(destination: pubsub.Destination, pattern?: MatchSpec): void; } export default Queue;