From 73c0c0071e34393dc889fe90151cd3aaf1a70ec6 Mon Sep 17 00:00:00 2001 From: Kenneth Giusti Date: Thu, 20 Jun 2019 16:12:39 -0400 Subject: [PATCH] Add the "transport_options" parameter to the amqp1 and kafka drivers. Change-Id: I5ca6ec2cb30b8d7f18e1770f80024957bc029bf3 --- oslo_messaging/_drivers/impl_amqp1.py | 5 ++++- oslo_messaging/_drivers/impl_kafka.py | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/oslo_messaging/_drivers/impl_amqp1.py b/oslo_messaging/_drivers/impl_amqp1.py index b8d005a96..d464742cd 100644 --- a/oslo_messaging/_drivers/impl_amqp1.py +++ b/oslo_messaging/_drivers/impl_amqp1.py @@ -299,7 +299,7 @@ class ProtonDriver(base.BaseDriver): def send(self, target, ctxt, message, wait_for_reply=False, timeout=None, call_monitor_timeout=None, - retry=None): + retry=None, transport_options=None): """Send a message to the given target. :param target: destination for message @@ -322,6 +322,9 @@ class ProtonDriver(base.BaseDriver): 0 means no retry N means N retries :type retry: int + :param transport_options: transport-specific options to apply to the + sending of the message (TBD) + :type transport_options: dictionary """ request = marshal_request(message, ctxt, None, call_monitor_timeout) diff --git a/oslo_messaging/_drivers/impl_kafka.py b/oslo_messaging/_drivers/impl_kafka.py index ea3d10204..dc4fe0960 100644 --- a/oslo_messaging/_drivers/impl_kafka.py +++ b/oslo_messaging/_drivers/impl_kafka.py @@ -399,7 +399,7 @@ class KafkaDriver(base.BaseDriver): LOG.info("Kafka messaging driver shutdown") def send(self, target, ctxt, message, wait_for_reply=None, timeout=None, - call_monitor_timeout=None, retry=None): + call_monitor_timeout=None, retry=None, transport_options=None): raise NotImplementedError( 'The RPC implementation for Kafka is not implemented')