[Event Hubs] Add test for exceeding max listeners on send (#4637)

Azure · Aug 2, 2019 · 859fc21 · 859fc21
1 parent f3026bd
commit 859fc21
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 1 deletion.
diff --git a/sdk/eventhub/event-hubs/src/eventHubSender.ts b/sdk/eventhub/event-hubs/src/eventHubSender.ts
@@ -644,7 +644,7 @@ export class EventHubSender extends LinkEntity {
             );
             return resolve();
           } catch (err) {
-            err = translate(err);
+            err = translate(err.innerError || err);
             log.error(
               "[%s] An error occurred while sending the message",
               this._context.connectionId,

diff --git a/sdk/eventhub/event-hubs/test/sender.spec.ts b/sdk/eventhub/event-hubs/test/sender.spec.ts
@@ -355,6 +355,24 @@ describe("EventHub Sender #RunnableInBrowser", function(): void {
       }
       await Promise.all(promises);
     });
+
+    it("should be sent successfully in parallel, even when exceeding max event listener count of 1000", async function(): Promise<
+      void
+    > {
+      const senderCount = 1200;
+      try {
+        const producer = client.createProducer();
+        const promises = [];
+        for (let i = 0; i < senderCount; i++) {
+          promises.push(producer.send([{ body: `Hello World ${i}` }]));
+        }
+        await Promise.all(promises);
+      } catch (err) {
+        debug("An error occurred while running the test: ", err);
+        throw err;
+      }
+    });
+
     it("should be sent successfully in parallel by multiple senders", async function(): Promise<
       void
     > {