osmq.broker.sorter
Classes 
MessageSortingThread
Pipeline