Added Queue interface and moved channel based queue implementation into test.