@polymathnetwork/launchpad-rabbitmq - npm Package Compare versions

Comparing version 1.1.4 to 1.1.5

dist/index.d.ts

@@ -1,4 +0,4 @@
-import publisher from 'queue/publisher';
-import consumer from 'queue/consumer';
-import rabbitmq from 'queue';
+import publisher from './queue/publisher';
+import consumer from './queue/consumer';
+import rabbitmq from './queue';
 export { rabbitmq, consumer, publisher };

dist/index.js

@@ -7,8 +7,8 @@ "use strict";
 exports.publisher = exports.consumer = exports.rabbitmq = void 0;
-const publisher_1 = __importDefault(require("queue/publisher"));
+const publisher_1 = __importDefault(require("./queue/publisher"));
 exports.publisher = publisher_1.default;
-const consumer_1 = __importDefault(require("queue/consumer"));
+const consumer_1 = __importDefault(require("./queue/consumer"));
 exports.consumer = consumer_1.default;
-const queue_1 = __importDefault(require("queue"));
+const queue_1 = __importDefault(require("./queue"));
 exports.rabbitmq = queue_1.default;
 //# sourceMappingURL=index.js.map

dist/queue/base.d.ts

@@ -1,12 +0,2 @@
-/// <reference types="node" />
-import amqp from 'amqplib';
-import EventEmitter from 'events';
-type BaseConnection = {
-    getConnection: () => amqp.Connection | null;
-    getChannel: () => amqp.ConfirmChannel | null;
-    initialize: () => Promise<boolean>;
-    cleanUp: (isClosureIntentional?: boolean) => Promise<void>;
-    event: EventEmitter;
-};
+import { BaseConnection } from '../types';
 export declare const baseConnection: (connectionType: string) => BaseConnection;
-export {};

dist/queue/base.js

@@ -17,6 +17,6 @@ "use strict";
 const amqplib_1 = __importDefault(require("amqplib"));
-const constants_1 = require("config/constants");
 const events_1 = __importDefault(require("events"));
-const logger_1 = __importDefault(require("monitoring/logger"));
-const queue_1 = __importDefault(require("queue"));
+const constants_1 = require("../config/constants");
+const logger_1 = __importDefault(require("../monitoring/logger"));
+const queue_1 = __importDefault(require("../queue"));
 const baseConnection = (connectionType) => {
@@ -23,0 +23,0 @@ let connection = null;

dist/queue/consumer.d.ts

@@ -1,3 +0,3 @@
-import { QueueConsumer } from 'types';
+import { QueueConsumer } from '../types';
 declare const consumer: QueueConsumer;
 export default consumer;

dist/queue/consumer.js

@@ -15,6 +15,6 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const logger_1 = __importDefault(require("monitoring/logger"));
-const base_1 = require("queue/base");
-const constants_1 = require("config/constants");
-const queue_1 = __importDefault(require("queue"));
+const logger_1 = __importDefault(require("../monitoring/logger"));
+const base_1 = require("../queue/base");
+const constants_1 = require("../config/constants");
+const queue_1 = __importDefault(require("../queue"));
 const consumer = (() => {
@@ -21,0 +21,0 @@ const connection = (0, base_1.baseConnection)('consumer');

dist/queue/index.d.ts

@@ -1,3 +0,3 @@
-import { RabbitMQ } from 'types';
+import { RabbitMQ } from '../types';
 declare const rabbitMQ: RabbitMQ;
 export default rabbitMQ;

dist/queue/publisher.d.ts

@@ -1,3 +0,3 @@
-import { QueuePublisher } from 'types';
+import { QueuePublisher } from '../types';
 declare const publisher: QueuePublisher;
 export default publisher;

dist/queue/publisher.js

@@ -15,5 +15,5 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const logger_1 = __importDefault(require("monitoring/logger"));
-const base_1 = require("queue/base");
-const constants_1 = require("config/constants");
+const logger_1 = __importDefault(require("../monitoring/logger"));
+const base_1 = require("../queue/base");
+const constants_1 = require("../config/constants");
 const publisher = (() => {
@@ -20,0 +20,0 @@ const connection = (0, base_1.baseConnection)('publisher');

dist/types/index.d.ts

 /// <reference types="node" />
+/// <reference types="node" />
+import amqp from 'amqplib';
+import EventEmitter from 'events';
 export type RabbitMQ = {
@@ -26,1 +29,8 @@ initialize: (config: RabbitMQConfig) => RabbitMQConfig;
 };
+export type BaseConnection = {
+    getConnection: () => amqp.Connection | null;
+    getChannel: () => amqp.ConfirmChannel | null;
+    initialize: () => Promise<boolean>;
+    cleanUp: (isClosureIntentional?: boolean) => Promise<void>;
+    event: EventEmitter;
+};

package.json

 {
   "name": "@polymathnetwork/launchpad-rabbitmq",
-  "version": "1.1.4",
+  "version": "1.1.5",
   "description": "Helper package to interact with rabbitmq",
@@ -5,0 +5,0 @@ "files": [

No alert changes

Improved metrics

Total package byte prevSize

30010

increased by0.31%

No dependency changes