forked from p15670423/monkey
Island: Rename subscribe_to_topics() -> setup_island_event_subscribers()
This commit is contained in:
parent
0ca13eb93d
commit
fd7a00a225
|
@ -1,2 +1,2 @@
|
|||
from .version import Version
|
||||
from .subscribe_to_topics import subscribe_to_topics
|
||||
from .subscribe_to_topics import setup_island_event_subscribers
|
||||
|
|
|
@ -10,7 +10,7 @@ import gevent.hub
|
|||
import requests
|
||||
from gevent.pywsgi import WSGIServer
|
||||
|
||||
from monkey_island.cc import Version, subscribe_to_topics
|
||||
from monkey_island.cc import Version, setup_island_event_subscribers
|
||||
from monkey_island.cc.deployment import Deployment
|
||||
from monkey_island.cc.server_utils.consts import ISLAND_PORT
|
||||
from monkey_island.cc.server_utils.island_logger import get_log_file_path
|
||||
|
@ -62,7 +62,7 @@ def run_monkey_island():
|
|||
_initialize_mongodb_connection(config_options.start_mongodb, config_options.data_dir)
|
||||
_start_island_server(ip_addresses, island_args.setup_only, config_options, container)
|
||||
|
||||
subscribe_to_topics(container)
|
||||
setup_island_event_subscribers(container)
|
||||
|
||||
|
||||
def _extract_config(island_args: IslandCmdArgs) -> IslandConfigOptions:
|
||||
|
|
|
@ -3,7 +3,7 @@ from monkey_island.cc.event_queue import IslandEventTopic, PyPubSubIslandEventQu
|
|||
from monkey_island.cc.services.reset_agent_configuration import reset_agent_configuration
|
||||
|
||||
|
||||
def subscribe_to_topics(container: DIContainer):
|
||||
def setup_island_event_subscribers(container: DIContainer):
|
||||
event_queue = container.resolve(PyPubSubIslandEventQueue)
|
||||
|
||||
event_queue.subscribe(
|
||||
|
|
Loading…
Reference in New Issue