Skip to content
Snippets Groups Projects
Commit f3d58e9e authored by Nathan Hertz's avatar Nathan Hertz
Browse files

Added threaded argument to appropriate docstrings

parent e63ad66d
No related branches found
No related tags found
No related merge requests found
......@@ -84,6 +84,7 @@ class Channel(Generic[ChannelDef]):
def connect(self, threaded: bool = False, **kwargs: Union[int, str]):
"""
Initialize connection to AMQP server given a CAPO profile
:param threaded: Specifies if the caller is a separate thread
Keyword arguments for the AMQP connection. These do not need to be specified:
:param: hostname: Hostname to connect to
......@@ -149,6 +150,7 @@ class Channel(Generic[ChannelDef]):
:param pattern: Pattern to be used as routing key
Optional keyword arguments
:param auto_ack: If true, consumer automatically acknowledges when it consumes a message
:param threaded: Boolean that specifies whether a thread is the caller
"""
def unwrapping_callback(channel, delivery, headers, message):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment