From 068847706380987074ab13a1479762b6fccbe032 Mon Sep 17 00:00:00 2001
From: Diego Garcia <diego.garcia@tradeshift.com>
Date: Thu, 1 Sep 2022 12:42:58 -0600
Subject: [PATCH] refactor(typos): Fix ampq typos

---
 src/AmqpConnectionManager.ts      | 10 +++++-----
 test/AmqpConnectionManagerTest.ts |  6 +++---
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/AmqpConnectionManager.ts b/src/AmqpConnectionManager.ts
index 35453d71..2ed41c67 100644
--- a/src/AmqpConnectionManager.ts
+++ b/src/AmqpConnectionManager.ts
@@ -13,7 +13,7 @@ const HEARTBEAT_IN_SECONDS = 5;
 export type ConnectionUrl =
     | string
     | amqp.Options.Connect
-    | { url: string; connectionOptions?: AmpqConnectionOptions };
+    | { url: string; connectionOptions?: AmqpConnectionOptions };
 
 export interface ConnectListener {
     (arg: { connection: amqp.Connection; url: string | amqp.Options.Connect }): void;
@@ -23,7 +23,7 @@ export interface ConnectFailedListener {
     (arg: { err: Error; url: string | amqp.Options.Connect | undefined }): void;
 }
 
-export type AmpqConnectionOptions = (ConnectionOptions | TcpSocketConnectOpts) & {
+export type AmqpConnectionOptions = (ConnectionOptions | TcpSocketConnectOpts) & {
     noDelay?: boolean;
     timeout?: number;
     keepAlive?: boolean;
@@ -66,7 +66,7 @@ export interface AmqpConnectionManagerOptions {
         | undefined;
 
     /** Connection options, passed as options to the amqplib.connect() method. */
-    connectionOptions?: AmpqConnectionOptions;
+    connectionOptions?: AmqpConnectionOptions;
 }
 
 /* istanbul ignore next */
@@ -80,7 +80,7 @@ function neverThrows() {
 }
 
 export interface IAmqpConnectionManager {
-    connectionOptions?: AmpqConnectionOptions;
+    connectionOptions?: AmqpConnectionOptions;
     heartbeatIntervalInSeconds: number;
     reconnectTimeInSeconds: number;
 
@@ -157,7 +157,7 @@ export default class AmqpConnectionManager extends EventEmitter implements IAmqp
         | (() => Promise<ConnectionUrl | ConnectionUrl[]>);
     private _urls?: ConnectionUrl[];
 
-    public connectionOptions: AmpqConnectionOptions | undefined;
+    public connectionOptions: AmqpConnectionOptions | undefined;
     public heartbeatIntervalInSeconds: number;
     public reconnectTimeInSeconds: number;
 
diff --git a/test/AmqpConnectionManagerTest.ts b/test/AmqpConnectionManagerTest.ts
index b215eb94..5d55b092 100644
--- a/test/AmqpConnectionManagerTest.ts
+++ b/test/AmqpConnectionManagerTest.ts
@@ -1,4 +1,4 @@
-import origAmpq from 'amqplib';
+import origAmqp from 'amqplib';
 import chai from 'chai';
 import chaiString from 'chai-string';
 import { once } from 'events';
@@ -15,7 +15,7 @@ describe('AmqpConnectionManager', function () {
     let amqp: AmqpConnectionManager | undefined;
 
     beforeEach(() => {
-        jest.spyOn(origAmpq, 'connect').mockImplementation(((url: string) =>
+        jest.spyOn(origAmqp, 'connect').mockImplementation(((url: string) =>
             amqplib.connect(url)) as any);
         amqplib.reset();
     });
@@ -169,7 +169,7 @@ describe('AmqpConnectionManager', function () {
     });
 
     it('should timeout connect', async () => {
-        jest.spyOn(origAmpq, 'connect').mockImplementation((): any => {
+        jest.spyOn(origAmqp, 'connect').mockImplementation((): any => {
             return promiseTools.delay(200);
         });
         amqp = new AmqpConnectionManager('amqp://localhost');