Worker Thread

A Worker Thread is the unit of code doing real data processing on the event data received. It receives the events from the filter and may generate some output events afterward. A work thread may or may not emit output events depending on its internal design.

type WorkerThread struct {
	Name          string
	Groupid       string
	Concurrency   int
	MsgBroker     *MessageWrapper
	LatestMessage *Message
	Log           *log.LogWraper
}