Skip to content

Commit 2529a92

Browse files
committed
redis fix
1 parent ed15313 commit 2529a92

File tree

1 file changed

+1
-11
lines changed

1 file changed

+1
-11
lines changed

redis.go

+1-11
Original file line numberDiff line numberDiff line change
@@ -138,19 +138,9 @@ func (t *RedisTransport) AddSubscriber(s *LocalSubscriber) error {
138138
t.Lock()
139139
t.subscribers.Add(s)
140140
t.Unlock()
141-
142141
if s.RequestLastEventID != "" {
143-
lastEventID, err := t.client.Get(context.Background(), lastEventIDKey).Result()
144-
if err != nil {
145-
return fmt.Errorf("redis failed to get last event id: %w", err)
146-
}
147-
148-
if lastEventID == "" {
149-
lastEventID = EarliestLastEventID
150-
}
151-
s.HistoryDispatched(lastEventID)
142+
s.HistoryDispatched(EarliestLastEventID)
152143
}
153-
154144
s.Ready()
155145

156146
return nil

0 commit comments

Comments
 (0)