astra/plc-mirror
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Pass the correct context to Consumer.Start so that it will actually stop

Browse source 
when singalled
This commit is contained in:
Max Ignatenko 2024-03-29 10:15:48 +00:00
parent 567885af60
commit 7c09c37a51
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
cmd/consumer/main.go
View file

@ -137,10 +137,12 @@ func runConsumers(ctx context.Context, db *gorm.DB, doneCh chan struct{}) {
c, err := NewConsumer(subCtx, &remote, db)
if err != nil {
log.Error().Err(err).Msgf("Failed to create a consumer for %q: %s", remote.Host, err)
cancel()
continue
}
if err := c.Start(ctx); err != nil {
if err := c.Start(subCtx); err != nil {
log.Error().Err(err).Msgf("Failed ot start a consumer for %q: %s", remote.Host, err)
cancel()
continue
}