appolo-rabbit - npm Package Compare versions

Comparing version 8.0.0 to 8.0.1

package.json

@@ -20,3 +20,3 @@ {
   "main": "./index.js",
-  "version": "8.0.0",
+  "version": "8.0.1",
   "license": "MIT",
@@ -23,0 +23,0 @@ "repository": {

src/rabbit.js

@@ -19,2 +19,5 @@ "use strict";
     }
+    bind(item) {
+        return this.topology.bindKey(item);
+    }
     onUnhandled(handler) {
@@ -21,0 +24,0 @@ this.handlers.onUnhandled(handler);

src/rabbit.ts

@@ -18,2 +18,3 @@ import {} from '@appolo/engine';
 import {EventDispatcher} from "@appolo/events";
+import {IBindingOptions} from "./queues/IQueueOptions";
 
@@ -44,2 +45,5 @@ @define()
 
+    public bind(item: IBindingOptions):Promise<void>{
+        return this.topology.bindKey(item)
+    }
 
@@ -46,0 +50,0 @@ public onUnhandled(handler: IHandlerFn) {

src/topology/topology.js

@@ -61,5 +61,5 @@ "use strict";
     _bindKeys() {
-        return utils_1.Promises.map(this._options.bindings, item => this._bindKey(item));
+        return utils_1.Promises.map(this._options.bindings, item => this.bindKey(item));
     }
-    _bindKey(item) {
+    bindKey(item) {
         let queue = this._queues.get(item.queue);
@@ -66,0 +66,0 @@ if (!queue) {

src/topology/topology.ts

@@ -101,6 +101,6 @@ import {IOptions} from "../common/IOptions";
     private _bindKeys() {
-        return Promises.map(this._options.bindings, item => this._bindKey(item))
+        return Promises.map(this._options.bindings, item => this.bindKey(item))
     }
 
-    private _bindKey(item: IBindingOptions) {
+    public bindKey(item: IBindingOptions) {
         let queue = this._queues.get(item.queue);
@@ -107,0 +107,0 @@

No alert changes

Improved metrics

Total package byte prevSize

126298

increased by0.25%

Lines of code

2455

increased by0.29%

No dependency changes