Message Wrapper

The wrapper packs up the output from the worker thread and convert it into a format ready for the event broker to publish under the corresponding topic.

type MessageWrapper struct {
	MsgBroker      *streamer.StatefulBroker
	LatestMessage  *Message
	WorkThreadName string
}