Skip to content

Commit

Permalink
Added a ConsumerDataflow guide.
Browse files Browse the repository at this point in the history
  • Loading branch information
houseofcat committed Apr 30, 2024
1 parent 2d5b9b0 commit 6eaebbe
Show file tree
Hide file tree
Showing 5 changed files with 814 additions and 4 deletions.
1 change: 1 addition & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,7 @@ developer.
* Getting started with *RabbitMQ.Dataflows* [Publisher](https://github.com/houseofcat/RabbitMQ.Dataflows/blob/main/guides/rabbitmq/Publisher.md).
* Getting started with *RabbitMQ.Dataflows* [AutoPublisher](https://github.com/houseofcat/RabbitMQ.Dataflows/blob/main/guides/rabbitmq/AutoPublisher.md).
* Getting started with *RabbitMQ.Dataflows* [Consumer](https://github.com/houseofcat/RabbitMQ.Dataflows/blob/main/guides/rabbitmq/Consumer.md).
* ***Getting started with RabbitMQ.Dataflows [ConsumerDataflow](https://github.com/houseofcat/RabbitMQ.Dataflows/blob/main/guides/rabbitmq/ConsumerDataflow.md)***.

More to come!

Expand Down
1 change: 1 addition & 0 deletions RabbitMQ.Dataflows.sln
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,7 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "rabbitmq", "rabbitmq", "{5C
guides\rabbitmq\ChannelPools.md = guides\rabbitmq\ChannelPools.md
guides\rabbitmq\ConnectionPools.md = guides\rabbitmq\ConnectionPools.md
guides\rabbitmq\Consumer.md = guides\rabbitmq\Consumer.md
guides\rabbitmq\ConsumerDataflow.md = guides\rabbitmq\ConsumerDataflow.md
guides\rabbitmq\Publisher.md = guides\rabbitmq\Publisher.md
guides\rabbitmq\Serialization.md = guides\rabbitmq\Serialization.md
EndProjectSection
Expand Down
4 changes: 2 additions & 2 deletions guides/rabbitmq/Consumer.md
Original file line number Diff line number Diff line change
Expand Up @@ -81,11 +81,11 @@ using HouseofCat.Compression.Recyclable;
using HouseofCat.Encryption;
using HouseofCat.Hashing;
using HouseofCat.RabbitMQ;
using HouseofCat.RabbitMQ.Services.Extensions;
using HouseofCat.RabbitMQ.Extensions;
using HouseofCat.Serialization;

// Step 1: Load RabbitOptions from a file.
var rabbitOptions = await RabbitExtensions.GetRabbitOptionsFromJsonFileAsync("./SampleRabbitOptions.json");
var rabbitOptions = await RabbitOptionsExtensions.GetRabbitOptionsFromJsonFileAsync("./SampleRabbitOptions.json");

// Step 2: Setup your Providers (all but ISerializationProvider is optional)
var jsonProvider = new JsonProvider();
Expand Down
Loading

0 comments on commit 6eaebbe

Please sign in to comment.