diff options
| author | Kenneth Giusti <kgiusti@gmail.com> | 2019-06-20 16:12:39 -0400 |
|---|---|---|
| committer | Kenneth Giusti <kgiusti@gmail.com> | 2019-06-20 16:12:39 -0400 |
| commit | 73c0c0071e34393dc889fe90151cd3aaf1a70ec6 (patch) | |
| tree | edf468a42f971aa36d4e53d706ca378a85511339 | |
| parent | b8c3a1ea592e1c0a41e331991959ea00e1f87945 (diff) | |
| download | oslo-messaging-73c0c0071e34393dc889fe90151cd3aaf1a70ec6.tar.gz | |
Add the "transport_options" parameter to the amqp1 and kafka drivers.
Change-Id: I5ca6ec2cb30b8d7f18e1770f80024957bc029bf3
| -rw-r--r-- | oslo_messaging/_drivers/impl_amqp1.py | 5 | ||||
| -rw-r--r-- | 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 b8d005a..d464742 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 ea3d102..dc4fe09 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') |