Commit dd337c65 authored by mohammad.salama's avatar mohammad.salama

Changed The Message ID in the System

parent 9cdeea93
...@@ -64,6 +64,7 @@ namespace SchedulerNode.RedisQueuer ...@@ -64,6 +64,7 @@ namespace SchedulerNode.RedisQueuer
return RedisConnectionError; return RedisConnectionError;
} }
id = message.Tag + ":" + message.LocalPriority + ":" + temp; id = message.Tag + ":" + message.LocalPriority + ":" + temp;
//id = Guid.NewGuid().ToString();
return id; return id;
} }
......
...@@ -54,11 +54,9 @@ namespace SchedulerNode.Services ...@@ -54,11 +54,9 @@ namespace SchedulerNode.Services
return (new Acknowledgement return (new Acknowledgement
{ {
ReplyCode = "OK on Send : id = " + message.MsgId + " ==> Message Reached Queue" ReplyCode = "OK ",
+ " with priority : " + message.LocalPriority, RequestID = Guid.NewGuid().ToString() + ":" + MyId
});
RequestID = reqId
});
} }
...@@ -78,7 +76,7 @@ namespace SchedulerNode.Services ...@@ -78,7 +76,7 @@ namespace SchedulerNode.Services
return new Acknowledgement return new Acknowledgement
{ {
ReplyCode = res, ReplyCode = res,
RequestID = "id = some id" RequestID = Guid.NewGuid().ToString() + ":" + MyId
}; };
} }
} }
......
...@@ -44,3 +44,4 @@ ...@@ -44,3 +44,4 @@
2.0 2.0
2.0 2.0
2.0 2.0
2.0
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment