       )
        failOnError(err, <span class="hljs-string">&quot;Failed to register a consumer&quot;</span>)

        forever := <span class="hljs-built_in">make</span>(<span class="hljs-keyword">chan</span> <span class="hljs-keyword">bool</span>)

        <span class="hljs-keyword">go</span> <span class="hljs-keyword">func</span>() {
                <span class="hljs-keyword">for</span> d := <span class="hljs-keyword">range</span> msgs {
                        log.Printf(<span class="hljs-string">&quot; 