diff --git a/celery_app/server.py b/celery_app/server.py
index 499aff0..159f6cd 100644
--- a/celery_app/server.py
+++ b/celery_app/server.py
@@ -7,5 +7,5 @@
 host = rabbit_creds["host"]
 port = rabbit_creds["port"]
 
-app = Celery("celery_app/tasks", broker=f"pyamqp://{user}:{password}@{host}:{port}//")
+app = Celery("celery_app/tasks", broker=f"librabbitmq://{user}:{password}@{host}:{port}//")
 app.autodiscover_tasks(["celery_app"])