diff --git a/src/python/blazingmq/dev/it/process/broker.py b/src/python/blazingmq/dev/it/process/broker.py index ec15a536e..610a60a31 100644 --- 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 index 8ba26c1bb..bafb52e44 100644 --- a/src/python/blazingmq/dev/workspace/__init__.py +++ b/src/python/blazingmq/dev/workspace/__init__.py @@ -436,7 +436,7 @@ 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, ), ), @@ -444,7 +444,7 @@ class Proto: 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, ), ), @@ -452,7 +452,7 @@ 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, ), ),