Make a custom storage to fetch 1 msg and skip thread number messages
Implement prioritized messages selection instead of select / reject