Initial import of queue code from channels package