| 1 | "use strict";
|
| 2 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 3 | const EventEmitter_1 = require("./EventEmitter");
|
| 4 | const ChannelManager_1 = require("./ChannelManager");
|
| 5 | const TaskManager_1 = require("./TaskManager");
|
| 6 | const Event_1 = require("./Event");
|
| 7 | const EventListener_1 = require("./EventListener");
|
| 8 | const RPCManager_1 = require("./RPCManager");
|
| 9 | class AMQPManager {
|
| 10 | get events() {
|
| 11 | return EventEmitter_1.AMQPEventEmitter;
|
| 12 | }
|
| 13 | get rpc() {
|
| 14 | return RPCManager_1.RPCManager;
|
| 15 | }
|
| 16 | get channelManager() {
|
| 17 | return ChannelManager_1.channelManager;
|
| 18 | }
|
| 19 | get tasks() {
|
| 20 | if (!this.taskManager) {
|
| 21 | this.taskManager = new TaskManager_1.TaskManager();
|
| 22 | }
|
| 23 | return this.taskManager;
|
| 24 | }
|
| 25 | createEvent(options) {
|
| 26 | return new Event_1.Event(options);
|
| 27 | }
|
| 28 | createEventListener(options) {
|
| 29 | return new EventListener_1.EventListener(options);
|
| 30 | }
|
| 31 | setConnectionURI(uri) {
|
| 32 | ChannelManager_1.channelManager.setConnectionURI(uri);
|
| 33 | }
|
| 34 | disconnect(cb) {
|
| 35 | ChannelManager_1.channelManager.disconnect(cb);
|
| 36 | }
|
| 37 | reconnect(cb) {
|
| 38 | ChannelManager_1.channelManager.reconnect(cb);
|
| 39 | }
|
| 40 | }
|
| 41 | exports.AMQPManager = AMQPManager;
|
| 42 | |
| \ | No newline at end of file |