Fix panic on nil message

2022-04-03 07:52:42 +10:00 · 2022-04-03 07:52:42 +10:00 · 42173343fa
parent 9ee8d0f867
commit 42173343fa
1 changed files with 2 additions and 3 deletions
--- a/msgbus.go
+++ b/msgbus.go
@ -484,9 +484,8 @@ func (mb *MessageBus) Subscribe(id, topic string, opts ...SubscribeOption) chan
 		var n int
 		log.Debugf("subscriber wants to start from %d", o.Index)
 		q.ForEach(func(item interface{}) error {
-			msg := item.(Message)
-			log.Debugf("found #%v", msg)
-			if msg.ID >= o.Index {
+			if msg, ok := item.(Message); ok && msg.ID >= o.Index {
+				log.Debugf("found #%v", msg)
 				ch <- msg
 				n++
 			}