openstack/oslo.messaging
Code Issues Proposed changes

Add the "transport_options" parameter to the amqp1 and kafka drivers.

Browse Source 
Change-Id: I5ca6ec2cb30b8d7f18e1770f80024957bc029bf3
This commit is contained in:
Kenneth Giusti 2019-06-20 16:12:39 -04:00
parent b8c3a1ea59
commit 73c0c0071e
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
oslo_messaging/_drivers/impl_amqp1.py
View File

@ -299,7 +299,7 @@ class ProtonDriver(base.BaseDriver):
def send(self, target, ctxt, message, def send(self, target, ctxt, message,
wait_for_reply=False, wait_for_reply=False,
timeout=None, call_monitor_timeout=None, timeout=None, call_monitor_timeout=None,
retry=None): retry=None, transport_options=None):
"""Send a message to the given target. """Send a message to the given target.
:param target: destination for message :param target: destination for message
@ -322,6 +322,9 @@ class ProtonDriver(base.BaseDriver):
0 means no retry 0 means no retry
N means N retries N means N retries
:type retry: int :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, request = marshal_request(message, ctxt, None,
call_monitor_timeout) call_monitor_timeout)

2
oslo_messaging/_drivers/impl_kafka.py
View File

@ -399,7 +399,7 @@ class KafkaDriver(base.BaseDriver):
LOG.info("Kafka messaging driver shutdown") LOG.info("Kafka messaging driver shutdown")
def send(self, target, ctxt, message, wait_for_reply=None, timeout=None, 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( raise NotImplementedError(
'The RPC implementation for Kafka is not implemented') 'The RPC implementation for Kafka is not implemented')