diff options
| -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') |