diff --git a/pubsub/message.go b/pubsub/message.go index 13dfbc69eb1..00076ef6463 100644 --- a/pubsub/message.go +++ b/pubsub/message.go @@ -119,5 +119,7 @@ func (m *Message) done(ack bool) { return } m.calledDone = true - m.doneFunc(m.ackID, ack, m.receiveTime) + if m.doneFunc != nil { + m.doneFunc(m.ackID, ack, m.receiveTime) + } }