OMGeeky/flucto-heisskleber
1
0
Fork 0
mirror of https://github.com/OMGeeky/flucto-heisskleber.git synced 2025-12-27 06:29:32 +01:00
Code Issues Packages Projects Releases Wiki Activity

fixed mixed up publisher subscriber addresses

Browse Source
This commit is contained in:
Aljoscha Sander
2023-11-27 11:58:58 +01:00
parent 07508d2899
commit 43a6071ad3
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
heisskleber/broker/zmq_broker.py
View File

@@ -46,8 +46,8 @@ def zmq_broker(config: BrokerConf) -> None:
xsub = ctx.socket(zmq.XSUB)
try:
bind_socket(xpub, config.publisher_address, "publisher", config.verbose)
bind_socket(xsub, config.subscriber_address, "subscriber", config.verbose)
bind_socket(xpub, config.subscriber_address, "publisher", config.verbose)
bind_socket(xsub, config.publisher_address, "subscriber", config.verbose)
create_proxy(xpub, xsub, config.verbose)
except BrokerBindingError as e:
print(e)