diff --git a/storage/memory/storage.go b/storage/memory/storage.go
index 48d83df..1a60f9b 100644
--- a/storage/memory/storage.go
+++ b/storage/memory/storage.go
@@ -66,7 +66,7 @@ func (s *Storage) GetMessages(ctx context.Context, keys []string, lastEventId in
 			if m.IsExpired(now) {
 				continue
 			}
-			if m.EventId < lastEventId {
+			if m.EventId <= lastEventId {
 				continue
 			}
 			results = append(results, m.SseMessage)