Skip to content
Snippets Groups Projects
Commit 59fbb796 authored by Sam Kagan's avatar Sam Kagan
Browse files

Fixed cap svc's AAT AMQP routing key

parent ec7bbdba
No related branches found
No related tags found
No related merge requests found
......@@ -217,6 +217,9 @@ class MessageSender(SenderIF):
exchange=self.exchange,
retry=True,
)
logger.debug(
f"Sent message to exchange '{self.exchange.name}' with routing_key '{message['routing_key']}' and body '{message}'"
)
class MessageReceiver(ReceiverIF, ConsumerMixin):
......
......@@ -138,7 +138,7 @@ class ArchiveMessageArchitect(MessageArchitectIF):
@staticmethod
def _make_archive_routing_key(cr: "CapabilityRequest") -> str:
return f"{cr.controller.routing_key_prefix}{cr.capability_name}_{cr.id}"
return f"{cr.controller.routing_key_prefix}{cr.capability_name}.{cr.id}"
@staticmethod
def get_message_template(msg_type: str) -> DictView:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment