bypass script for broker

Signed-off-by: Jean-Louis Leroy <[email protected]>
bloomberg · Jan 11, 2024 · d4b3794 · d4b3794
1 parent 6d0966f
commit d4b3794
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 10 deletions.
diff --git a/src/python/blazingmq/dev/it/process/broker.py b/src/python/blazingmq/dev/it/process/broker.py
@@ -31,15 +31,10 @@ def open_non_blocking(path, flags):
 
 class Broker(blazingmq.dev.it.process.bmqproc.BMQProcess):
     def __init__(self, config: ws.Broker, cluster, **kwargs):
+        kwargs["cwd"].joinpath("storage", "archive").mkdir(parents=True)
         super().__init__(
             config.name,
-            [
-                "./run",
-                " set:appConfig/networkInterfaces/tcpInterface/useNtf=False"
-                " set:appConfig/dispatcherConfig/sessions/processorConfig/queueSizeLowWatermark=100"
-                " set:appConfig/dispatcherConfig/queues/processorConfig/queueSizeLowWatermark=100"
-                " set:appConfig/dispatcherConfig/clusters/processorConfig/queueSizeLowWatermark=100",
-            ],
+            ["bin/bmqbrkr.tsk", "etc"],
             process_log_category="bmqbrkr",
             **kwargs,
         )

diff --git a/src/python/blazingmq/dev/workspace/__init__.py b/src/python/blazingmq/dev/workspace/__init__.py
@@ -436,23 +436,23 @@ class Proto:
                         num_processors=4,
                         processor_config=mqbcfg.DispatcherProcessorParameters(
                             queue_size=500000,
-                            queue_size_low_watermark=100000,
+                            queue_size_low_watermark=100,
                             queue_size_high_watermark=200000,
                         ),
                     ),
                     queues=mqbcfg.DispatcherProcessorConfig(
                         num_processors=8,
                         processor_config=mqbcfg.DispatcherProcessorParameters(
                             queue_size=500000,
-                            queue_size_low_watermark=100000,
+                            queue_size_low_watermark=100,
                             queue_size_high_watermark=200000,
                         ),
                     ),
                     clusters=mqbcfg.DispatcherProcessorConfig(
                         num_processors=4,
                         processor_config=mqbcfg.DispatcherProcessorParameters(
                             queue_size=500000,
-                            queue_size_low_watermark=100000,
+                            queue_size_low_watermark=100,
                             queue_size_high_watermark=200000,
                         ),
                     ),