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