CreateQueueWorkers creates queue workers to read from the queue.

GetEventPriority returns the priority of the flow event message.

MessageQueue is the heap based priority queue implementation of the MessageQueue implementation.

QMessage is the message that is enqueued for each incoming message.

MessagePriorityFunc - the callback function to derive priority of a message.