test

Signed-off-by: Gabriele Santomaggio <[email protected]>
rabbitmq · Nov 26, 2024 · 4465dd9 · 4465dd9
1 parent 4d8a8a2
commit 4465dd9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/perfTest/cmd/silent.go b/perfTest/cmd/silent.go
@@ -92,7 +92,7 @@ func printStats() {
 						ConfirmedMessagesPerSecond = float64(atomic.LoadInt32(&confirmedMessageCount)) / float64(v) * 1000
 					}
 					p := gomsg.NewPrinter(language.English)
-					logInfo(p.Sprintf("+Published %8.1f msg/s | Confirmed %8.1f msg/s |  Consumed %8.1f msg/s |  %3v  |  %3v  |  msg sent: %3v  |   latency: %d ms",
+					logInfo(p.Sprintf("++Published %8.1f msg/s | Confirmed %8.1f msg/s |  Consumed %8.1f msg/s |  %3v  |  %3v  |  msg sent: %3v  |   latency: %d ms",
 						PMessagesPerSecond, ConfirmedMessagesPerSecond, CMessagesPerSecond, decodeRate(), decodeBody(), atomic.LoadInt64(&messagesSent), averageLatency))
 				}
 			}

diff --git a/pkg/stream/brokers.go b/pkg/stream/brokers.go
@@ -51,7 +51,7 @@ func newTCPParameterDefault() *TCPParameters {
 	return &TCPParameters{
 		RequestedHeartbeat:    defaultHeartbeat,
 		RequestedMaxFrameSize: 1048576,
-		WriteBuffer:           8192,
+		WriteBuffer:           2097152,
 		//ReadBuffer:            65536,
 		ReadBuffer: 2097152,
 		NoDelay:    false,