Socket
Socket
Sign inDemoInstall

amqp-connection-manager

Package Overview
Dependencies
Maintainers
1
Versions
67
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

amqp-connection-manager - npm Package Compare versions

Comparing version 4.1.1 to 4.1.2

dist/cjs/MessageStore.js

1

dist/cjs/index.js

@@ -7,2 +7,3 @@ "use strict";

exports.AmqpConnectionManagerClass = exports.connect = void 0;
/* eslint-disable @typescript-eslint/no-namespace */
const AmqpConnectionManager_js_1 = __importDefault(require("./AmqpConnectionManager.js"));

@@ -9,0 +10,0 @@ exports.AmqpConnectionManagerClass = AmqpConnectionManager_js_1.default;

2

dist/esm/ChannelWrapper.d.ts

@@ -31,3 +31,3 @@ /// <reference types="node" />

}
interface PublishOptions extends Options.Publish {
export interface PublishOptions extends Options.Publish {
/** Message will be rejected after timeout ms */

@@ -34,0 +34,0 @@ timeout?: number;

import AmqpConnectionManager, { AmqpConnectionManagerOptions, ConnectionUrl, IAmqpConnectionManager } from './AmqpConnectionManager.js';
import { PublishOptions } from './ChannelWrapper.js';
export type { AmqpConnectionManagerOptions, ConnectionUrl, IAmqpConnectionManager as AmqpConnectionManager, } from './AmqpConnectionManager.js';
export type { CreateChannelOpts, default as ChannelWrapper, SetupFunc, Channel, } from './ChannelWrapper.js';
import { Options as AmqpLibOptions } from 'amqplib';
export declare namespace Options {
type Connect = AmqpLibOptions.Connect;
type AssertQueue = AmqpLibOptions.AssertQueue;
type DeleteQueue = AmqpLibOptions.DeleteQueue;
type AssertExchange = AmqpLibOptions.AssertExchange;
type DeleteExchange = AmqpLibOptions.DeleteExchange;
type Publish = PublishOptions;
type Consume = AmqpLibOptions.Consume;
type Get = AmqpLibOptions.Get;
}
export declare function connect(urls: ConnectionUrl | ConnectionUrl[] | undefined | null, options?: AmqpConnectionManagerOptions): IAmqpConnectionManager;

@@ -5,0 +17,0 @@ export { AmqpConnectionManager as AmqpConnectionManagerClass };

@@ -0,1 +1,2 @@

/* eslint-disable @typescript-eslint/no-namespace */
import AmqpConnectionManager from './AmqpConnectionManager.js';

@@ -2,0 +3,0 @@ export function connect(urls, options) {

{
"name": "amqp-connection-manager",
"version": "4.1.1",
"version": "4.1.2",
"description": "Auto-reconnect and round robin support for amqplib.",

@@ -5,0 +5,0 @@ "module": "./dist/esm/index.js",

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc