///
import * as Rx from 'rx';
import RxConnection from './RxConnection';
/**
* Factory for RxAmqpLib.
*/
declare class RxAmqpLib {
/**
* Create a new instance of RxConnection, which wraps the amqplib Connection obj.
*
* @param url URL to AMQP host. eg: amqp://localhost/
* @param options Custom AMQP options
* @returns {RxConnection}
*/
static newConnection(url: string, options?: any): Rx.Observable;
}
export default RxAmqpLib;