transit

Adapters.sln

@@ -3,7 +3,7 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio Version 17
 VisualStudioVersion = 17.0.31903.59
 MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DDO_Application", "DDO_Application\DDO_Application.csproj", "{D568A3F5-FA39-4244-8CD8-0B179626F4F8}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DDO_Application", "DDO_Application\DDO_Application.csproj", "{D568A3F5-FA39-4244-8CD8-0B179626F4F8}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution

DDO_Application/Startup.cs

@@ -24,16 +24,23 @@ namespace DDO_Application {
             var ActiveMQ = Configuration.GetSection("ActiveMQ").Get<configActiveMQ>().Endpoint;
             var msgQueues = Configuration.GetSection("TestQueues").Get<configTestQueues>();
 
+            string queue1 = "SMEV3_V12.GET_REQUEST_RESPONSE";
+            string queue2 = "CONTINGENT.APPLICATION_INC";
+            string queue3 = "CONTINGENT.MV.REQ";
+            string queue4 = "CONTINGENT.MV.RESP";
+
             services.AddControllers();
             services.AddSwaggerGen(c => {c.SwaggerDoc("v1", new OpenApiInfo { Title = "DDO_Application", Version = "v1" }); });
             services.AddHostedService<ApiHostedService>();
             services.AddSingleton<IApiService, ApiProcessingService>();
             // turn enable ActiveMQ support in project
-            //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "172.17.100.121", port: 61616, "contingent", "RjQ66VWS") })
-            services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "192.168.2.19", port: 5672, "guest", "guest") })
+            services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "172.17.100.121", port: 61616, "contingent", "RjQ66VWS") })
+            //services.AddActiveMq("ddoApp-cluster", new[] { Endpoint.Create(host: "192.168.2.19", port: 5672, "guest", "guest") })
             //services.AddActiveMq("ddoApp-cluster", new[] { ActiveMQ })
-                    .AddProducer<MessageProducer>(msgQueues.Out)
-                    .AddTypedConsumer<TestMessage, MessageCunsomer>(msgQueues.In, RoutingType.Multicast);
+                    //.AddProducer<MessageProducer>(queue1)
+                    .AddTypedConsumer<TestMessage, MessageCunsomer>(queue3, RoutingType.Multicast);
+                    //.AddProducer<MessageProducer>(msgQueues.Out)
+                    //.AddTypedConsumer<TestMessage, MessageCunsomer>(msgQueues.In, RoutingType.Multicast);
             services.AddActiveMqHostedService();
         }