Method Serve

user/event_processor/processer.go:37–44

Write event 处理器读取事件

()

// Write event 处理器读取事件
func (this *EventProcessor) Serve() {
	for {
		select {
		case e := <-this.incoming:
			this.dispatch(e)
		}
	}
}

func (this *EventProcessor) dispatch(map_e event.IEventStruct) {
	// 如果需要dump那就直接写到文件中去