diff --git a/certstream/core.py b/certstream/core.py
index e119296..4f17d3b 100644
--- a/certstream/core.py
+++ b/certstream/core.py
@@ -44,7 +44,7 @@ def _on_error(self, _, ex):
         if type(ex) == KeyboardInterrupt:
             raise
         if self.on_error_handler:
-            self.on_error_handler(ex)
+            self.on_error_handler(self, ex)
         certstream_logger.error("Error connecting to CertStream - {} - Sleeping for a few seconds and trying again...".format(ex))
 
 def listen_for_events(message_callback, url, skip_heartbeats=True, setup_logger=True, on_open=None, on_error=None, **kwargs):