/// <reference types="node" />
import { Queue as QueueContract } from "../../Engine/Queue";
import { Configuration } from "./Configuration";
import { Service as Bus } from "../../Bus/Service";
import { Author } from "../../Domain/Author";
import * as amqp from "amqplib";
export declare class Queue implements QueueContract {
    name: string;
    protected connectionString: string;
    protected connection: amqp.Connection;
    protected channel: amqp.ConfirmChannel;
    protected bus: Bus;
    protected active: number;
    constructor(options: Configuration, bus: Bus);
    connect(): Promise<void>;
    close(): Promise<void>;
    dispatchSourceScans(author: Author): Promise<void>;
    working(): boolean;
    work(): Promise<void>;
    workSources(): void;
    protected handleSource(message: amqp.Message): Promise<void>;
    setup(): Promise<void>;
    protected toJsonBuffer(data: any): Buffer;
}