Struct messageHandler

functional_producer_test.go:365–370

}

type messageHandler struct {
	*testing.T
	h         func(ConsumerGroupSession, *ConsumerMessage)
	started   chan struct{}
	startOnce sync.Once
}

func (h *messageHandler) Setup(s ConsumerGroupSession) error   { return nil }
func (h *messageHandler) Cleanup(s ConsumerGroupSession) error { return nil }