Merge pull request #50 from PanDAWMS/flin

msg_proc: verbose option per msg queue
PanDAWMS · Feb 29, 2024 · 03ec1bc · 03ec1bc
2 parents c274dd4 + b83ee1b
commit 03ec1bc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pandacommon/pandamsgbkr/msg_processor.py b/pandacommon/pandamsgbkr/msg_processor.py
@@ -63,7 +63,7 @@ def get_mb_proxy(name, sconf, qconf, mode="listener", **kwargs):
         max_buffer_len=qconf.get("max_buffer_len", 999),
         buffer_block_sec=qconf.get("buffer_block_sec", 10),
         use_transaction=qconf.get("use_transaction", True),
-        verbose=sconf.get("verbose", False),
+        verbose=sconf.get("verbose", False) or qconf.get("verbose", False),
         **kwargs
     )
     return mb_proxy
@@ -264,7 +264,7 @@ def _parse_config(self):
                     'username': 'someuser',
                     'passcode': 'xxxxyyyyzzzz',
                     'vhost': '/somehost',
-                    'verbose': True,
+                    'verbose': False,
                 },
                 ...
             }
@@ -273,6 +273,7 @@ def _parse_config(self):
                     'enable': True,
                     'server': 'Server_1',
                     'destination': '/queue/some_queue',
+                    'verbose': True,
                 },
                 ...
             }
@@ -284,7 +285,6 @@ def _parse_config(self):
                     'n_threads': 1,
                     'in_queue': 'Queue_1',
                     'out_queue': 'Queue_2',
-                    'verbose': True,
                 },
                 ...
             }