diff --git a/src/event_handlers/stateful_event_handler.py b/src/event_handlers/stateful_event_handler.py
index f03e105..211a139 100644
--- a/src/event_handlers/stateful_event_handler.py
+++ b/src/event_handlers/stateful_event_handler.py
@@ -26,9 +26,7 @@ class StatefulEventHandler(EventHandlerBase):
             except StopIteration:
                 self.reset()
                 return
-            if response_anchor not in self.subscriptions:
-                self.subscriptions.add(response_anchor)
-                self.zmq_sub_socket.setsockopt_string(zmq.SUBSCRIBE, response_anchor)
+            self.subscribe(response_anchor)
             response_data = json.dumps({
                 'anchor': response_anchor,
                 'data': response_data,