Skip to content

Commit

Permalink
Update ConsumerDataflow.md
Browse files Browse the repository at this point in the history
  • Loading branch information
houseofcat committed Apr 30, 2024
1 parent 2ebca7f commit 255669d
Showing 1 changed file with 8 additions and 6 deletions.
14 changes: 8 additions & 6 deletions guides/rabbitmq/ConsumerDataflow.md
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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();
```

Expand Down

0 comments on commit 255669d

Please sign in to comment.