- case reader_ctrl := <-control_ch:
- if reader_ctrl.Command == "EXIT" {
- event_chan <- 0
- log.Debug("Topic reader on topic: ", topic, " for type: ", type_id, " - stopped")
- data_ch <- nil //Signal to job handler
+ case readerCtrl := <-controlCh:
+ if readerCtrl.Command == "EXIT" {
+ eventChan <- 0
+ log.Debug("Topic reader on topic: ", topic, typeLabel, typeId, " - stopped")
+ dataCh <- nil //Signal to job handler