From 3344300f84ef7e328809e951cc234c7e649ed162 Mon Sep 17 00:00:00 2001
From: Mike Salvatore <mike.s.salvatore@gmail.com>
Date: Thu, 29 Sep 2022 12:39:17 -0400
Subject: [PATCH] Common: Accept a lock in LockingAgentEventQueueDecorator's
constructor
---
.../common/event_queue/locking_agent_event_queue_decorator.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/monkey/common/event_queue/locking_agent_event_queue_decorator.py b/monkey/common/event_queue/locking_agent_event_queue_decorator.py
index 2a5e6828b..c3aa8097a 100644
--- a/monkey/common/event_queue/locking_agent_event_queue_decorator.py
+++ b/monkey/common/event_queue/locking_agent_event_queue_decorator.py
@@ -11,8 +11,8 @@ class LockingAgentEventQueueDecorator(IAgentEventQueue):
Makes an IAgentEventQueue thread-safe by locking publish()
"""
- def __init__(self, agent_event_queue: IAgentEventQueue):
- self._lock = Lock()
+ def __init__(self, agent_event_queue: IAgentEventQueue, lock: Lock):
+ self._lock = lock
self._agent_event_queue = agent_event_queue
def subscribe_all_events(self, subscriber: AgentEventSubscriber):