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, new EventEmitter_1.AMQPEventEmitter('random-event-emitter-' + Math.random()));
|
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 | finalize() {
|
41 | ChannelManager_1.channelManager.finalize();
|
42 | }
|
43 | }
|
44 | exports.AMQPManager = AMQPManager;
|
45 |
|
\ | No newline at end of file |