Island: Register IIslandEventQueue instance in DI container
This commit is contained in:
parent
237f6d01b6
commit
27c8a1019b
|
@ -14,6 +14,7 @@ from common.aws import AWSInstance
|
||||||
from common.common_consts.telem_categories import TelemCategoryEnum
|
from common.common_consts.telem_categories import TelemCategoryEnum
|
||||||
from common.event_queue import IAgentEventQueue, PyPubSubAgentEventQueue
|
from common.event_queue import IAgentEventQueue, PyPubSubAgentEventQueue
|
||||||
from common.utils.file_utils import get_binary_io_sha256_hash
|
from common.utils.file_utils import get_binary_io_sha256_hash
|
||||||
|
from monkey.common.event_queue import IIslandEventQueue, PyPubSubIslandEventQueue
|
||||||
from monkey_island.cc.repository import (
|
from monkey_island.cc.repository import (
|
||||||
AgentBinaryRepository,
|
AgentBinaryRepository,
|
||||||
FileAgentConfigurationRepository,
|
FileAgentConfigurationRepository,
|
||||||
|
@ -64,6 +65,7 @@ def initialize_services(container: DIContainer, data_dir: Path):
|
||||||
)
|
)
|
||||||
container.register(Publisher, Publisher)
|
container.register(Publisher, Publisher)
|
||||||
container.register_instance(IAgentEventQueue, container.resolve(PyPubSubAgentEventQueue))
|
container.register_instance(IAgentEventQueue, container.resolve(PyPubSubAgentEventQueue))
|
||||||
|
container.register_instance(IIslandEventQueue, container.resolve(PyPubSubIslandEventQueue))
|
||||||
|
|
||||||
_register_repositories(container, data_dir)
|
_register_repositories(container, data_dir)
|
||||||
_register_services(container)
|
_register_services(container)
|
||||||
|
|
Loading…
Reference in New Issue