From 7eaec450a190ab2d4eca7e23cff01305d9350d93 Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Wed, 19 Aug 2020 10:20:43 +0100
Subject: [PATCH] support error handler in memory broker (#1947)

---
 broker/memory/memory.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/broker/memory/memory.go b/broker/memory/memory.go
index a934daf5..8d90e933 100644
--- a/broker/memory/memory.go
+++ b/broker/memory/memory.go
@@ -97,6 +97,9 @@ func (m *memoryBroker) Publish(topic string, msg *broker.Message, opts ...broker
 
 	for _, sub := range subs {
 		if err := sub.handler(msg); err != nil {
+			if eh := sub.opts.ErrorHandler; eh != nil {
+				eh(msg, err)
+			}
 			continue
 		}
 	}