Create multiple queues for incoming messages. The size is the number of receiver threads.
For message which is sent to same task, it will be stored in the same queue to preserve the message order.