fix queue stream, add queue import