diff --git a/fs/contube/memory.go b/fs/contube/memory.go
index e5886f53..c3425c63 100644
--- a/fs/contube/memory.go
+++ b/fs/contube/memory.go
@@ -89,10 +89,9 @@ func (f *MemoryQueueFactory) NewSourceTube(ctx context.Context, configMap Config
 			<-ctx.Done()
 			f.release(t)
 		}()
-
+		c := f.getOrCreateChan(t)
 		go func() {
 			defer wg.Done()
-			c := f.getOrCreateChan(t)
 			for {
 				select {
 				case <-ctx.Done():