Skip to content

Commit 9512242

Browse files
committed
RADAS: change the request_queue to request_channel in config
As topic is also a valid destination to send, use queue is not correct
1 parent 268d002 commit 9512242

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

charon/config.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ def __init__(self, data: Dict):
3030
self.__umb_host: str = data.get("umb_host", None)
3131
self.__umb_host_port: str = data.get("umb_host_port", "5671")
3232
self.__result_queue: str = data.get("result_queue", None)
33-
self.__request_queue: str = data.get("request_queue", None)
33+
self.__request_chan: str = data.get("request_channel", None)
3434
self.__client_ca: str = data.get("client_ca", None)
3535
self.__client_key: str = data.get("client_key", None)
3636
self.__client_key_pass_file: str = data.get("client_key_pass_file", None)
@@ -51,7 +51,7 @@ def validate(self) -> bool:
5151
if not self.__result_queue:
5252
logger.error("Missing the queue setting to receive signing result in UMB!")
5353
return False
54-
if not self.__request_queue:
54+
if not self.__request_chan:
5555
logger.error("Missing the queue setting to send signing request in UMB!")
5656
return False
5757
if self.__client_ca and not os.access(self.__client_ca, os.R_OK):
@@ -81,8 +81,8 @@ def umb_target(self) -> str:
8181
def result_queue(self) -> str:
8282
return self.__result_queue.strip()
8383

84-
def request_queue(self) -> str:
85-
return self.__request_queue.strip()
84+
def request_channel(self) -> str:
85+
return self.__request_chan.strip()
8686

8787
def client_ca(self) -> str:
8888
return self.__client_ca.strip()

charon/pkgs/radas_sign.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ def on_start(self, event):
206206
ssl_domain=self._ssl
207207
)
208208
if conn:
209-
self._sender = self._container.create_sender(conn, self.rconf.request_queue())
209+
self._sender = self._container.create_sender(conn, self.rconf.request_channel())
210210

211211
def on_sendable(self, event):
212212
if not self._message_sent:

0 commit comments

Comments
 (0)