From 255669da7c0455b1220d14ff49e4a9114876e845 Mon Sep 17 00:00:00 2001 From: "Tristan (HouseCat) Hyams" Date: Mon, 29 Apr 2024 21:35:45 -0500 Subject: [PATCH] Update ConsumerDataflow.md --- guides/rabbitmq/ConsumerDataflow.md | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/guides/rabbitmq/ConsumerDataflow.md b/guides/rabbitmq/ConsumerDataflow.md index aab9dcc..4a2f092 100644 --- a/guides/rabbitmq/ConsumerDataflow.md +++ b/guides/rabbitmq/ConsumerDataflow.md @@ -524,6 +524,14 @@ dataflow.WithFinalization( }); ``` +### ConsumerDataflow - Start +Now that everything is wired up and configured, just start the Dataflow! This will kick start the Consumer +internally and start processing all the messages in your queque and executing your methods. + +```csharp +await dataflow.StartAsync(); +``` + ## ConsumerDataflow - Full Example All Together ```csharp using HouseofCat.Compression.Recyclable; @@ -662,13 +670,7 @@ dataflow.WithFinalization( state.ReceivedMessage?.AckMessage(); }); -``` -### ConsumerDataflow - Start -Now that everything is wired up and configured, just start the Dataflow! This will kick start the Consumer -internally and start processing all the messages in your queque and executing your methods. - -```csharp await dataflow.StartAsync(); ```