This is an automated email from the ASF dual-hosted git repository.

blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 272f647  Use the simpler Process in the sample project
272f647 is described below

commit 272f64762b71876efaa218ff0882b3532b70f617
Author: Daniel Blankensteiner <[email protected]>
AuthorDate: Mon Oct 24 16:16:42 2022 +0200

    Use the simpler Process in the sample project
---
 samples/Processing/Worker.cs | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/samples/Processing/Worker.cs b/samples/Processing/Worker.cs
index 25ad087..caa9d54 100644
--- a/samples/Processing/Worker.cs
+++ b/samples/Processing/Worker.cs
@@ -36,11 +36,7 @@ public class Worker : BackgroundService
             .Topic("persistent://public/default/mytopic")
             .Create();
 
-        var options = new ProcessingOptions
-        {
-            MaxDegreeOfParallelism = 5
-        };
-        await consumer.Process(ProcessMessage, options, cancellationToken);
+        await consumer.Process(ProcessMessage, cancellationToken);
     }
 
     private ValueTask ProcessMessage(IMessage<string> message, 
CancellationToken cancellationToken)

Reply via email to