diff --git a/store_message.go b/store_message.go index 7cf7fb97..333d0ab8 100644 --- a/store_message.go +++ b/store_message.go @@ -205,6 +205,7 @@ func (m *MessageStore) processMessageLoop(ctx context.Context) { m.logger.Error("unable to process message", zap.Error(err)) } + m.muDeviceCaches.Unlock() continue }