romved console logging, Tracing Working Fine, All Working Fine

GrpcMessage/obj/Debug/net6.0/GrpcMessageNode.csproj.FileListAbsolute.txt

@@ -100,6 +100,7 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\System.Diagnostics.DiagnosticSource.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
+D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.AssemblyInfo.cs

GrpcMessage/obj/staticwebassets.pack.sentinel

@@ -56,3 +56,4 @@
 2.0
 2.0
 2.0
+2.0

HTTPMessageGenerator/obj/Debug/net6.0/HTTPMessageGenerator.csproj.FileListAbsolute.txt

@@ -26,6 +26,7 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessage
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerGen.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
+D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.AssemblyInfo.cs

HTTPMessageNode/Program.cs

@@ -15,7 +15,7 @@ builder.Services.AddSwaggerGen();
 builder.Services.AddDiscoveryClient();
 //builder.Configuration.GetValue<string>("database:conn");
 const string serviceName = "http-protocol-node";
-
+/*
 builder.Logging.AddOpenTelemetry(options =>
 {
     options
@@ -24,7 +24,7 @@ builder.Logging.AddOpenTelemetry(options =>
                 .AddService(serviceName))
         .AddConsoleExporter();
 
-});
+});*/
 
 
 builder.Services.AddOpenTelemetry()

HTTPMessageNode/obj/Debug/net6.0/HTTPMessageNode.csproj.FileListAbsolute.txt

@@ -55,6 +55,7 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessage
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\System.Diagnostics.DiagnosticSource.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
+D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageNode\obj\Debug\net6.0\HTTPMessageNode.AssemblyInfo.cs

HTTPMessageNode/obj/staticwebassets.pack.sentinel

@@ -27,3 +27,5 @@
 2.0
 2.0
 2.0
+2.0
+2.0

MessageGeneratorGRPC/obj/Debug/net6.0/GRPCMessageGenerator.csproj.FileListAbsolute.txt

@@ -25,6 +25,7 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGene
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerGen.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
+D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\GRPCMessageGenerator.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\GRPCMessageGenerator.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\GRPCMessageGenerator.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\GRPCMessageGenerator.AssemblyInfo.cs

MessagesConsumer/Program.cs

@@ -28,13 +28,13 @@ while (!token.IsCancellationRequested)
 
     turn ^= 1;
 
-    Console.WriteLine("\n\n\n\n");
+    //Console.WriteLine("\n\n\n\n");
     
     TotalWorker.work(provs[turn]);
     
     turn ^= 1;
 
-    Console.WriteLine("**************************************************");
+    //Console.WriteLine("**************************************************");
 
     await Task.Delay(1000);
 }

MessagesConsumer/obj/Debug/net6.0/MessagesConsumer.csproj.FileListAbsolute.txt

@@ -10,6 +10,7 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesCon
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesConsumer\bin\Debug\net6.0\Pipelines.Sockets.Unofficial.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesConsumer\bin\Debug\net6.0\StackExchange.Redis.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesConsumer\bin\Debug\net6.0\System.IO.Pipelines.dll
+D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesConsumer\obj\Debug\net6.0\MessagesConsumer.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesConsumer\obj\Debug\net6.0\MessagesConsumer.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesConsumer\obj\Debug\net6.0\MessagesConsumer.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessagesConsumer\obj\Debug\net6.0\MessagesConsumer.AssemblyInfo.cs

PriorityStream/Program.cs

@@ -34,7 +34,7 @@ while (!token.IsCancellationRequested)
 
     turn ^= 1;
 
-    Console.WriteLine("**************************************************");
+    //Console.WriteLine("**************************************************");
 
     await Task.Delay(1000);
 }

PriorityStream/obj/Debug/net6.0/PriorityStream.csproj.FileListAbsolute.txt

@@ -10,7 +10,6 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStr
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStream\bin\Debug\net6.0\Pipelines.Sockets.Unofficial.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStream\bin\Debug\net6.0\StackExchange.Redis.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStream\bin\Debug\net6.0\System.IO.Pipelines.dll
-D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStream\obj\Debug\net6.0\PriorityStream.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStream\obj\Debug\net6.0\PriorityStream.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStream\obj\Debug\net6.0\PriorityStream.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\PriorityStream\obj\Debug\net6.0\PriorityStream.AssemblyInfo.cs

QueuerNode/Program.cs

@@ -20,7 +20,7 @@ MessageQueues.init();
 MongoMessagesShceduler.init();
 
 const string serviceName = "Scheduler-1";
-
+/*
 builder.Logging.AddOpenTelemetry(options =>
 {
     options
@@ -30,7 +30,7 @@ builder.Logging.AddOpenTelemetry(options =>
         .AddConsoleExporter();
 
 });
-
+*/
 
 builder.Services.AddOpenTelemetry()
       .ConfigureResource(resource => resource.AddService(serviceName))

QueuerNode/Services/QueueMessageService.cs

@@ -24,10 +24,16 @@ namespace SchedulerNode.Services
         public override Task<Acknowledgement> QueueMessage(Message message, ServerCallContext context)
         {
             DateTime current = DateTime.Now;
-            DateTime des = new DateTime(message.Year, message.Month, message.Day, message.Hour, message.Minute, 0);
 
             //Console.WriteLine("Message Receieved to Queuer !!");
-            if (message.Year == 0 || DateTime.Compare(des,current)<=0)
+            if (message.Year == 0 || message.Day == 0 || message.Month == 0)
+            {
+                return Task.FromResult(SendAsap(ref message));
+            }
+            
+            DateTime des = new DateTime(message.Year, message.Month, message.Day, message.Hour, message.Minute, 0);
+            
+            if (DateTime.Compare(des,current)<=0)
             {
                 return Task.FromResult(SendAsap(ref message));
             }

QueuerNode/obj/staticwebassets.pack.sentinel

@@ -49,3 +49,7 @@
 2.0
 2.0
 2.0
+2.0
+2.0
+2.0
+2.0

ScheduledMessagesHandler/obj/Debug/net6.0/ScheduledMessagesHandler.csproj.FileListAbsolute.txt

@@ -38,6 +38,7 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMe
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMessagesHandler\bin\Debug\net6.0\runtimes\linux\native\libmongocrypt.so
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMessagesHandler\bin\Debug\net6.0\runtimes\osx\native\libmongocrypt.dylib
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMessagesHandler\bin\Debug\net6.0\runtimes\win\native\mongocrypt.dll
+D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMessagesHandler\obj\Debug\net6.0\ScheduledMessagesHandler.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMessagesHandler\obj\Debug\net6.0\ScheduledMessagesHandler.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMessagesHandler\obj\Debug\net6.0\ScheduledMessagesHandler.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\ScheduledMessagesHandler\obj\Debug\net6.0\ScheduledMessagesHandler.AssemblyInfo.cs

Validator/Program.cs

@@ -13,7 +13,7 @@ var builder = WebApplication.CreateBuilder(args);
 builder.Services.AddGrpc();
 builder.Services.AddDiscoveryClient();
 const string serviceName = "Vaidator-1";
-
+/*
 builder.Logging.AddOpenTelemetry(options =>
 {
     options
@@ -24,7 +24,7 @@ builder.Logging.AddOpenTelemetry(options =>
 
 });
 
-
+*/
 builder.Services.AddOpenTelemetry()
       .ConfigureResource(resource => resource.AddService(serviceName))
       .WithTracing(tracing => tracing

Validator/obj/Debug/net6.0/Validator.csproj.FileListAbsolute.txt

@@ -55,6 +55,7 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\b
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\bin\Debug\net6.0\System.Diagnostics.DiagnosticSource.dll
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
+D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\obj\Debug\net6.0\Validator.csproj.AssemblyReference.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\obj\Debug\net6.0\Validator.GeneratedMSBuildEditorConfig.editorconfig
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\obj\Debug\net6.0\Validator.AssemblyInfoInputs.cache
 D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\Validator\obj\Debug\net6.0\Validator.AssemblyInfo.cs

Validator/obj/staticwebassets.pack.sentinel

@@ -10,3 +10,5 @@
 2.0
 2.0
 2.0
+2.0
+2.0