Switch to rabbit

BobAtParticular · Jun 6, 2022 · 52f5682 · 52f5682
1 parent c1803f8
commit 52f5682
Show file tree

Hide file tree

Showing 8 changed files with 32 additions and 5 deletions.
diff --git a/Billing/Billing.csproj b/Billing/Billing.csproj
@@ -7,6 +7,8 @@
   <ItemGroup>
     <PackageReference Include="NServiceBus" Version="7.*" />
     <PackageReference Include="NServiceBus.Storage.MongoDB" Version="2.2.0" />
+	<PackageReference Include="NServiceBus.RabbitMQ" Version="5.*" />
+	<PackageReference Include="RabbitMQ.Client" Version="5.*" />
     <ProjectReference Include="..\Messages\Messages.csproj" />
   </ItemGroup>
 </Project>
diff --git a/Billing/Program.cs b/Billing/Program.cs
@@ -12,7 +12,12 @@ static async Task Main()
 
             var endpointConfiguration = new EndpointConfiguration("Billing");
 
-            var transport = endpointConfiguration.UseTransport<LearningTransport>();
+            endpointConfiguration.EnableInstallers();
+
+            var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
+            transport.UseConventionalRoutingTopology();
+            transport.ConnectionString("host=localhost");
+
             var persistence = endpointConfiguration.UsePersistence<MongoPersistence>();
             persistence.DatabaseName("Tutorial_Billing");
 

diff --git a/ClientUI/ClientUI.csproj b/ClientUI/ClientUI.csproj
@@ -6,6 +6,8 @@
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="NServiceBus" Version="7.*" />
-    <ProjectReference Include="..\Messages\Messages.csproj" />
+	<PackageReference Include="NServiceBus.Storage.MongoDB" Version="2.2.0" />
+	<PackageReference Include="NServiceBus.RabbitMQ" Version="5.*" />
+    <ProjectReference Include="..\Messages\Messages.csproj" />	  
   </ItemGroup>
 </Project>
diff --git a/ClientUI/Program.cs b/ClientUI/Program.cs
@@ -14,7 +14,12 @@ static async Task Main()
 
             var endpointConfiguration = new EndpointConfiguration("ClientUI");
 
-            var transport = endpointConfiguration.UseTransport<LearningTransport>();
+
+            endpointConfiguration.EnableInstallers();
+
+            var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
+            transport.UseConventionalRoutingTopology();
+            transport.ConnectionString("host=localhost");
 
             var routing = transport.Routing();
             routing.RouteToEndpoint(typeof(PlaceOrder), "Sales");

diff --git a/Sales/Program.cs b/Sales/Program.cs
@@ -12,7 +12,11 @@ static async Task Main()
 
             var endpointConfiguration = new EndpointConfiguration("Sales");
 
-            var transport = endpointConfiguration.UseTransport<LearningTransport>();
+            endpointConfiguration.EnableInstallers();
+
+            var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
+            transport.UseConventionalRoutingTopology();
+            transport.ConnectionString("host=localhost");
 
             var persistence = endpointConfiguration.UsePersistence<MongoPersistence>();
             persistence.DatabaseName("Tutorial_Sales");

diff --git a/Sales/Sales.csproj b/Sales/Sales.csproj
@@ -7,6 +7,8 @@
   <ItemGroup>
     <PackageReference Include="NServiceBus" Version="7.*" />
     <PackageReference Include="NServiceBus.Storage.MongoDB" Version="2.2.0" />
+	<PackageReference Include="NServiceBus.Storage.MongoDB" Version="2.2.0" />
+	<PackageReference Include="NServiceBus.RabbitMQ" Version="5.*" />
     <ProjectReference Include="..\Messages\Messages.csproj" />
   </ItemGroup>
 </Project>
diff --git a/Shipping/Program.cs b/Shipping/Program.cs
@@ -13,7 +13,12 @@ static async Task Main()
 
             var endpointConfiguration = new EndpointConfiguration("Shipping");
 
-            var transport = endpointConfiguration.UseTransport<LearningTransport>();
+            endpointConfiguration.EnableInstallers();
+
+            var transport = endpointConfiguration.UseTransport<RabbitMQTransport>();
+            transport.UseConventionalRoutingTopology();
+            transport.ConnectionString("host=localhost");
+
             var persistence = endpointConfiguration.UsePersistence<MongoPersistence>();
             persistence.DatabaseName("Tutorial_Shipping");
 

diff --git a/Shipping/Shipping.csproj b/Shipping/Shipping.csproj
@@ -7,6 +7,8 @@
   <ItemGroup>
     <PackageReference Include="NServiceBus" Version="7.*" />
     <PackageReference Include="NServiceBus.Storage.MongoDB" Version="2.2.0" />
+	<PackageReference Include="NServiceBus.Storage.MongoDB" Version="2.2.0" />
+	<PackageReference Include="NServiceBus.RabbitMQ" Version="5.*" />
     <ProjectReference Include="..\Messages\Messages.csproj" />
   </ItemGroup>
 </Project>