Messages IDs are GUID, Scheduling Added, Redis Stream Sizes are Maintained,...

Messages IDs are GUID, Scheduling Added, Redis Stream Sizes are Maintained, Error Messages Not Complete Yet

PriorityStream/Extractor/Extractor.cs

@@ -109,6 +109,8 @@ namespace PriorityStream.Extractor
 
                 }
 
+                Writer.Writer.trimStream(stream, id);
+
                 if (!has_pending) id = ">";
 
                 return await Task.FromResult(id);

PriorityStream/Writer/Writer.cs

@@ -12,6 +12,7 @@ namespace PriorityStream.Writer
     {
         private static string Provider = "SYR";
         private static string Provider2 = "MTN";
+        private static int StreamMaxLength = 100000000;
 
         private static IDatabase db = null;
 
@@ -65,13 +66,23 @@ namespace PriorityStream.Writer
                 var serializedMessage = JsonConvert.SerializeObject(message);
 
                 Console.WriteLine("Writing  : " + message);
-               
+
                 var temp = await db.StreamAddAsync
                         (provider,
                                 new NameValueEntry[]
                                     {
                                 new NameValueEntry("message", serializedMessage)
-                                    });
+                                    },
+                                null,
+                                StreamMaxLength,
+                                true
+                        );
+                /*var temp = await db.StreamAddAsync
+                        (provider,
+                                new NameValueEntry[]
+                                    {
+                                new NameValueEntry("message", serializedMessage)
+                         );*/
 
                 return await Task.FromResult(true);
             }
@@ -84,5 +95,10 @@ namespace PriorityStream.Writer
 
         }
 
+    
+        public static void trimStream(string stream , RedisValue id)
+        {
+            
+        }
     }
 }

QueuerNode/RedisQueuer/MessageQueues.cs

@@ -18,6 +18,7 @@ namespace SchedulerNode.RedisQueuer
         private static string MTN = "MTN";
 
         private static int LEVELS = 6;
+        private static int StreamMaxLength = 100000000;
         private static IDatabase db = null;
         public static void init()
         {
@@ -88,7 +89,11 @@ namespace SchedulerNode.RedisQueuer
                                           new NameValueEntry[]
                                              {
                                                  new NameValueEntry("message", serializedMessage)
-                                             });
+                                             },
+                                          null,
+                                          StreamMaxLength,
+                                          true        
+                                     );
 
 
                 Console.WriteLine("Done Sending to stream : " + streamName);

ScheduledMessagesHandler/RedisQueuer/MessageQueues.cs

@@ -14,6 +14,7 @@ namespace ScheduledMessagesHandler.RedisQueuer
         private static string MTN = "MTN";
 
         private static int LEVELS = 6;
+        private static int StreamMaxLength = 100000000;
         private static IDatabase db = null;
         
         public static void init()
@@ -86,7 +87,10 @@ namespace ScheduledMessagesHandler.RedisQueuer
                                           new NameValueEntry[]
                                              {
                                                  new NameValueEntry("message", serializedMessage)
-                                             });
+                                             },
+                                null,
+                                StreamMaxLength,
+                                true);
 
 
                 //Console.WriteLine("Done Sending to stream : " + streamName);