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

connect(): made threaded default to False

parent 3cac8170
No related branches found
No related tags found
No related merge requests found
......@@ -81,7 +81,7 @@ class Channel(Generic[ChannelDef]):
self.chan: BlockingChannel = None
self.config: CapoConfig = None
def connect(self, threaded: bool, **kwargs: Union[int, str]):
def connect(self, threaded: bool = False, **kwargs: Union[int, str]):
"""
Initialize connection to AMQP server given a CAPO profile
......
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