1+ // This source code is dual-licensed under the Apache License, version
2+ // 2.0, and the Mozilla Public License, version 2.0.
3+ // Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15using RabbitMQ . Stream . Client ;
26using RabbitMQ . Stream . Client . Reliable ;
37
@@ -20,8 +24,7 @@ public static async Task Start()
2024 Console . WriteLine ( "Aggregate Batch Size: {0}" , AggregateBatchSize ) ;
2125 Console . WriteLine ( "Print Messages each: {0} messages" , ModPrintMessages ) ;
2226
23-
24- var config = new StreamSystemConfig ( ) { Heartbeat = TimeSpan . Zero } ;
27+ var config = new StreamSystemConfig ( ) { Heartbeat = TimeSpan . Zero } ;
2528 var system = await StreamSystem . Create ( config ) ;
2629 await BatchSend ( system , await RecreateStream ( system , "StandardBatchSend" ) ) ;
2730 await StandardProducerSend ( await RecreateStream ( system , "StandardProducerSendNoBatch" ) , system ) ;
@@ -78,7 +81,6 @@ private static async Task RProducerSend(string stream, StreamSystem system)
7881 await reliableProducer . Close ( ) ;
7982 }
8083
81-
8284 private static async Task RProducerBatchSend ( string stream , StreamSystem system )
8385 {
8486 Console . WriteLine ( "*****Reliable Producer Batch Send*****" ) ;
@@ -110,7 +112,6 @@ private static async Task RProducerBatchSend(string stream, StreamSystem system)
110112
111113 var messages = new List < Message > ( ) ;
112114
113-
114115 var start = DateTime . Now ;
115116 for ( ulong i = 1 ; i <= TotalMessages ; i ++ )
116117 {
@@ -137,7 +138,6 @@ private static async Task RProducerBatchSend(string stream, StreamSystem system)
137138 await producer . Close ( ) ;
138139 }
139140
140-
141141 private static async Task StandardProducerSend ( string stream , StreamSystem system )
142142 {
143143 Console . WriteLine ( "*****Standard Producer Send*****" ) ;
0 commit comments