A sender node will start sendersNumber instances of mqSenders. Each mqSender will send up to msgsPerProcessInSecond messages per concurrent process per second. Number of concurrent processes is equal to senderConcurrency. In other words sender node should send up to sendersNumber * senderConcurrency * msgsPerProcessInSecond messages, in batches of batchSizeSend messages. Each message has msgSizeBytes bytes.
A receiver node will start receiversNumber instances of mqReceiver. Each mqReceiver will receive messages in batches of up to batchSizeReceive. One receiver receives at most receiverConcurrency concurrent batches.
adamw
commented
1 year ago
Adds new configs: sendersNumber, senderConcurrency, receiversNumber, receiverConcurrency. Renames config: msgsPerSecond -> msgsPerProcessInSecond. Removes
maxSendInFlighconfig.A sender node will start
sendersNumberinstances ofmqSenders. EachmqSenderwill send up tomsgsPerProcessInSecondmessages per concurrent process per second. Number of concurrent processes is equal tosenderConcurrency. In other words sender node should send up tosendersNumber * senderConcurrency * msgsPerProcessInSecondmessages, in batches ofbatchSizeSendmessages. Each message hasmsgSizeBytesbytes.A receiver node will start
receiversNumberinstances ofmqReceiver. EachmqReceiverwill receive messages in batches of up tobatchSizeReceive. One receiver receives at mostreceiverConcurrencyconcurrent batches.