이벤트브로커에서 이벤트 처리

eventbroker.go

func (j *Job) Run(in <-chan *sarama.ConsumerMessage) <-chan *sarama.ConsumerMessage {
	out := make(chan *sarama.ConsumerMessage)

	for msg := range in {
		wg := sync.WaitGroup{}
		for _, eh := range j.eventHandlers {
			wg.Add(1)
			go func(eh *eventbroker.EventHandler) {
				defer wg.Done()
				/************
				 * 이벤트 처리 *
				 ************/
			}(eh)
		}
		wg.Wait()

		out <- msg
	}

	return out
}