diff --git a/pikachu/client.py b/pikachu/client.py index 165042e..26c8a21 100644 --- a/pikachu/client.py +++ b/pikachu/client.py @@ -115,12 +115,12 @@ def _set_dlx(channel, queue_config, queue_prefix, queue_name): @staticmethod def _build_url(): - scheme = AMQPClient._resolve_scheme(environ["MESSAGING_AMQP_PORT"]) - username = environ["MESSAGING_AMQP_USERNAME"] - password = environ["MESSAGING_AMQP_PASSWORD"] + scheme = AMQPClient._resolve_scheme(environ["AMQP_PORT"]) + username = environ["AMQP_USERNAME"] + password = environ["AMQP_PASSWORD"] authentication_credentials = f"{username}:{password}" - host = environ["MESSAGING_AMQP_HOST"] - virtual_host = environ["MESSAGING_AMQP_VIRTUAL_HOST"] + host = environ["AMQP_HOST"] + virtual_host = environ["AMQP_VIRTUAL_HOST"] return f"{scheme}://{authentication_credentials}@{host}{virtual_host}" @@ -160,7 +160,7 @@ def from_config(): with open("amqp-config.yml", "r") as f: config = yaml.safe_load(f) - queue_prefix = environ["MESSAGING_AMQP_QUEUE_PREFIX"] + queue_prefix = environ["AMQP_QUEUE_PREFIX"] consumer_configs = config["consumers"] consumers = [ diff --git a/setup.py b/setup.py index faefba3..7ab47b0 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ setuptools.setup( name="pikachu", - version="1.0", + version="1.1", author="Maciej GruszczyƄski", author_email="maciejgruszczysnki@surferseo.com", description="Wrapper around pika inspired by lapin for convenient AMQP operations in Python APIs",