func()

in internal/subscriber/subscribe.go [123:130]

• 8 lines of code
• 2 McCabe index (conditional complexity)

func (s *SubscriberService) consumeMessage(ctx context.Context, msg *pubsub.Message) {
	if err := processMessage(s, msg); err != nil {
		log.Printf("message not acknowledged: %v\n", err)
		msg.Nack()
		return
	}
	msg.Ack()
}