filter strategy callback by exchange name

Drakkar-Software · May 12, 2020 · b5007a5 · b5007a5
1 parent 3cb0ab4
commit b5007a5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/octobot_evaluators/evaluator/strategy_evaluator.py b/octobot_evaluators/evaluator/strategy_evaluator.py
@@ -51,7 +51,9 @@ async def start(self, bot_id: str) -> bool:
         """
         await super().start(bot_id)
         self.consumer_instance = await get_chan(MATRIX_CHANNEL, self.matrix_id).new_consumer(
-            self.strategy_matrix_callback, priority_level=self.priority_level)
+            self.strategy_matrix_callback,
+            priority_level=self.priority_level,
+            exchange_name=self.exchange_name)
         self._init_exchange_allowed_time_delta(self.exchange_name, self.matrix_id)
         return True