forked from p15670423/monkey
Agent: Rename PyPubSubEventQueue -> PyPubSubAgentEventQueue
This commit is contained in:
parent
a83446e0f2
commit
5b7d3bfb70
|
@ -10,7 +10,7 @@ from typing import List
|
||||||
from pubsub.core import Publisher
|
from pubsub.core import Publisher
|
||||||
|
|
||||||
import infection_monkey.tunnel as tunnel
|
import infection_monkey.tunnel as tunnel
|
||||||
from common.event_queue import IAgentEventQueue, PyPubSubEventQueue
|
from common.event_queue import IAgentEventQueue, PyPubSubAgentEventQueue
|
||||||
from common.events import CredentialsStolenEvent
|
from common.events import CredentialsStolenEvent
|
||||||
from common.network.network_utils import address_to_ip_port
|
from common.network.network_utils import address_to_ip_port
|
||||||
from common.utils.argparse_types import positive_int
|
from common.utils.argparse_types import positive_int
|
||||||
|
@ -205,7 +205,7 @@ class InfectionMonkey:
|
||||||
control_channel
|
control_channel
|
||||||
)
|
)
|
||||||
|
|
||||||
event_queue = PyPubSubEventQueue(Publisher())
|
event_queue = PyPubSubAgentEventQueue(Publisher())
|
||||||
InfectionMonkey._subscribe_events(event_queue, propagation_credentials_repository)
|
InfectionMonkey._subscribe_events(event_queue, propagation_credentials_repository)
|
||||||
|
|
||||||
puppet = self._build_puppet(propagation_credentials_repository, event_queue)
|
puppet = self._build_puppet(propagation_credentials_repository, event_queue)
|
||||||
|
|
Loading…
Reference in New Issue