Fix event sync issue

ella-to · Aug 18, 2024 · 5f87fe1 · 5f87fe1
1 parent b0454ab
commit 5f87fe1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 0 deletions.
diff --git a/event/sync_test.go b/event/sync_test.go
@@ -45,6 +45,8 @@ func TestEventSync(t *testing.T) {
 	}()
 	assert.NoError(t, err)
 
+	time.Sleep(1 * time.Second)
+
 	evt, err := bus.NewEvent(
 		bus.WithSubject("test.1"),
 		bus.WithData(struct {

diff --git a/event/test.db b/event/test.db
diff --git a/server/action.go b/server/action.go
@@ -223,5 +223,7 @@ func (s *Server) offlineConsumer(ctx context.Context, consumerId string) (err er
 		return err
 	}
 
+	s.consumers.Del(consumer.Subject, consumerId)
+
 	return nil
 }