diff --git a/Libraries/Core/Services/NotificationService.cs b/Libraries/Core/Services/NotificationService.cs index 27c25554..b1c91755 100644 --- a/Libraries/Core/Services/NotificationService.cs +++ b/Libraries/Core/Services/NotificationService.cs @@ -8,19 +8,22 @@ public class NotificationService { protected Dictionary> _messageQueue = new(); - public Dictionary> GetMessageQueue() + public Dictionary> GetMessageQueue() { - throw new NotImplementedException(); + return _messageQueue; } - public List GetMessageFromQueue(string sessionId) + public List? GetMessageFromQueue(string sessionId) { - throw new NotImplementedException(); + return _messageQueue.GetValueOrDefault(sessionId); } public void UpdateMessageOnQueue(string sessionId, List value) { - throw new NotImplementedException(); + if (_messageQueue.ContainsKey(sessionId)) + { + _messageQueue[sessionId] = value; + } } public bool Has(string sessionID) @@ -33,7 +36,9 @@ public class NotificationService /// public WsNotificationEvent Pop(string sessionID) { - throw new NotImplementedException(); + var result = Get(sessionID).First(); + Get(sessionID).Remove(result); + return result; } ///