@highoutput/amqp - npm Package Compare versions

Comparing version 0.5.2 to 0.5.3

build/lib/client.d.ts

@@ -22,2 +22,3 @@ /// <reference types="node" />
     private disconnected;
+    private receiverQueueAddress;
     constructor(connection: Connection, queue: string, options?: Partial<ClientOptions>);
@@ -24,0 +25,0 @@ send(...args: TInput): Promise<TOutput | null>;

build/lib/client.js

@@ -37,2 +37,3 @@ "use strict";
         });
+        this.receiverQueueAddress = `temp-queue://${this.queue}/${this.id}`;
     }
@@ -60,3 +61,3 @@ async send(...args) {
             this.sender.send({
-                reply_to: this.receiver.source.address,
+                reply_to: this.receiverQueueAddress,
                 correlation_id: correlationId,
@@ -107,8 +108,3 @@ body,
                 }),
-                util_1.openReceiver(this.connection, {
-                    source: {
-                        address: `temp-queue://${this.queue}/${this.id}`,
-                        dynamic: true,
-                    },
-                }),
+                util_1.openReceiver(this.connection, this.receiverQueueAddress),
             ]);
@@ -115,0 +111,0 @@ this.sender = sender;

build/lib/util.d.ts

 import { Receiver, Sender, Connection, ReceiverOptions, SenderOptions } from 'rhea';
-export declare function openReceiver(connection: Connection, options: ReceiverOptions): Promise<Receiver>;
+export declare function openReceiver(connection: Connection, options: ReceiverOptions | string): Promise<Receiver>;
 export declare function closeReceiver(receiver: Receiver): Promise<void>;
@@ -4,0 +4,0 @@ export declare function openSender(connection: Connection, options: SenderOptions): Promise<Sender>;

package.json

 {
   "name": "@highoutput/amqp",
-  "version": "0.5.2",
+  "version": "0.5.3",
   "description": "A simplified abstraction of the AMQP 1.0 protocol",
@@ -53,3 +53,3 @@ "keywords": [
   },
-  "gitHead": "d1bcd4513b0aee73108a1cf667a4e8d24c422c9f"
+  "gitHead": "c464cd8af094d79bb4236f4daac5b4253e5bfff5"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

61972

decreased by-0.06%

Lines of code

798

decreased by-0.37%

No dependency changes