Name	Size	Mode	Actions
__pycache__/	-	0755	rm
amq_manager.py	716	0644	editdlrm
collections.py	942	0644	editdlrm
compat.py	3444	0644	editdlrm
debug.py	2049	0644	editdlrm
div.py	941	0644	editdlrm
encoding.py	2297	0644	editdlrm
eventio.py	10159	0644	editdlrm
functional.py	10699	0644	editdlrm
imports.py	2089	0644	editdlrm
json.py	4088	0644	editdlrm
limits.py	2551	0644	editdlrm
objects.py	2043	0644	editdlrm
scheduling.py	2927	0644	editdlrm
text.py	2200	0644	editdlrm
time.py	272	0644	editdlrm
url.py	3909	0644	editdlrm
uuid.py	327	0644	editdlrm
__init__.py	698	0644	editdlrm

"""AMQP Management API utilities.""" from __future__ import annotations def get_manager(client, hostname=None, port=None, userid=None, password=None): """Get pyrabbit manager.""" import pyrabbit opt = client.transport_options.get def get(name, val, default): return (val if val is not None else opt('manager_%s' % name) or getattr(client, name, None) or default) host = get('hostname', hostname, 'localhost') port = port if port is not None else opt('manager_port', 15672) userid = get('userid', userid, 'guest') password = get('password', password, 'guest') return pyrabbit.Client(f'{host}:{port}', userid, password)