Update fleetspeak/src/server/spanner/messagestore.go

daschwanden · coperni · web-flow · commit 06e6ee52ca64 · 2025-03-03T10:11:52.000+01:00
Co-authored-by: coperni &lt;5769938+coperni@users.noreply.github.com&gt;
diff --git a/fleetspeak/src/server/spanner/messagestore.go b/fleetspeak/src/server/spanner/messagestore.go
@@ -773,5 +773,6 @@ func (d *Datastore) RegisterMessageProcessor(mp db.MessageProcessor) {
 }
 
 func (d *Datastore) StopMessageProcessor() {
+        d.pubsubTopic.Stop()
 	log.Error("+++ messagestore: StopMessageProcessor() called")
 }

Original file line number	Diff line number	Diff line change
`@@ -773,5 +773,6 @@ func (d *Datastore) RegisterMessageProcessor(mp db.MessageProcessor) {`
`773`	`773`	`}`
`774`	`774`
`775`	`775`	`func (d *Datastore) StopMessageProcessor() {`
	`776`	`+ d.pubsubTopic.Stop()`
`776`	`777`	`log.Error("+++ messagestore: StopMessageProcessor() called")`
`777`	`778`	`}`