implement queue message handling