diff --git a/celery_cloudwatch/__main__.py b/celery_cloudwatch/__main__.py
index 56d9805..edf5713 100644
--- a/celery_cloudwatch/__main__.py
+++ b/celery_cloudwatch/__main__.py
@@ -77,7 +77,7 @@ def main():
     config = config_schema(config_schema(config))
     config_ccwatch = config['ccwatch']
     options = {
-        'broker': config_ccwatch.get('broker'),
+        'broker': args.broker if args.broker else config_ccwatch.get('broker') ,
         'camera': config_ccwatch.get('camera'),
         'verbose': config_ccwatch.get('verbose'),
         'config': config