diff --git a/pytrade/broker.py b/pytrade/broker.py
index 1b50047..36b3dd2 100644
--- a/pytrade/broker.py
+++ b/pytrade/broker.py
@@ -72,7 +72,7 @@ def subscribe(
 
         # If we are already tracking this pair/granularity no need to resubscribe
         if key not in self._subscriptions:
-            self.client.subscribe(instrument, granularity, instrument_data.update)
+            self.client.subscribe(instrument, granularity, self._data_context.update)
             self._subscriptions.append(key)
 
         return instrument_data