fix: attempt to fix app config nats issue

Signed-off-by: Alexander Trost <[email protected]>
fivenet-app · Oct 9, 2024 · 9a071bd · 9a071bd
1 parent c2ef62a
commit 9a071bd
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/pkg/config/appconfig/events.go b/pkg/config/appconfig/events.go
@@ -18,7 +18,7 @@ const (
  UpdateSubject events.Type = "update"
 )
 
-func (c *Config) registerSubscriptions(ctx context.Context) error {
+func (c *Config) registerSubscriptions(ctx context.Context, bc context.Context) error {
  cfg := jetstream.StreamConfig{
  Name: "APPCONFIG",
  Description: "AppConfig update events",
@@ -46,10 +46,10 @@ func (c *Config) registerSubscriptions(ctx context.Context) error {
  c.jsCons = nil
  }
 
- c.jsCons, err = consumer.Consume(c.handleMessageFunc(ctx),
+ c.jsCons, err = consumer.Consume(c.handleMessageFunc(bc),
  c.js.ConsumeErrHandlerWithRestart(context.Background(), c.logger,
  func(_ context.Context, ctx context.Context) error {
- return c.registerSubscriptions(ctx)
+ return c.registerSubscriptions(bc, bc)
  }))
  if err != nil {
  return err

diff --git a/pkg/config/appconfig/load.go b/pkg/config/appconfig/load.go
@@ -86,7 +86,7 @@ func New(p Params) (IConfig, error) {
  return err
  }
 
- return cfg.registerSubscriptions(c)
+ return cfg.registerSubscriptions(c, ctx)
  }))
 
  p.LC.Append(fx.StopHook(func(ctx context.Context) error {