Lines Matching refs:outputChan

54 	outputChan := make(chan amqp.Publishing, 1)
55 	ch := &mockChannel{f: nullFunc, c: outputChan}
60 	case msg = <-outputChan:
86 	outputChan := make(chan amqp.Publishing, 1)
87 	ch := &mockChannel{f: nullFunc, c: outputChan}
93 	case msg = <-outputChan:
120 	outputChan := make(chan amqp.Publishing, 1)
121 	ch := &mockChannel{f: nullFunc, c: outputChan}
127 	case msg = <-outputChan:
169 	outputChan := make(chan amqp.Publishing, 1)
170 	ch := &mockChannel{f: checkReplyToFunc, c: outputChan}
180 	case msg = <-outputChan:
242 	outputChan := make(chan amqp.Publishing, 1)
243 	ch := &mockChannel{f: checkReplyToFunc, c: outputChan}
251 	case <-outputChan:
288 	outputChan := make(chan amqp.Publishing, 1)
289 	ch := &mockChannel{f: checkReplyToFunc, c: outputChan}
295 	case msg = <-outputChan:
337 	outputChan := make(chan amqp.Publishing, 1)
338 	ch := &mockChannel{f: checkReplyToFunc, c: outputChan}
344 	case msg = <-outputChan: