Hi all I have this piece of multithreaded code, however it is only executing the first queue in _queues. Could anyone give any pointer ?
function execute_queues!() @async begin amqp_connection!(_conn_def) do conn amqp_channel!(conn) do chan @sync for queue in _queues @async Threads.@spawn queue(chan) end end end end end
Note that the original poster on Slack cannot see your response here on Discourse. Consider transcribing the appropriate answer back to Slack, or pinging the poster here on Discourse so they can follow this thread.
(Original message ) (More Info)