Method safelyApplyInterceptor

interceptors.go:25–33

(interceptor ProducerInterceptor)

}

func (msg *ProducerMessage) safelyApplyInterceptor(interceptor ProducerInterceptor) {
	defer func() {
		if r := recover(); r != nil {
			Logger.Printf("Error when calling producer interceptor: %v, %v", interceptor, r)
		}
	}()

	interceptor.OnSend(msg)
}

func (msg *ConsumerMessage) safelyApplyInterceptor(interceptor ConsumerInterceptor) {
	defer func() {