Updated queue_sink; WORKS