# File lib/ruote/svc/dispatch_pool.rb, line 103 def do_threaded_dispatch(participant, msg) msg = Rufus::Json.dup(msg) # # the thread gets its own copy of the message # (especially important if the main thread does something with # the message 'during' the dispatch) # Maybe at some point a limit on the number of dispatch threads # would be OK. # Or maybe it's the job of an extension / subclass Thread.new { do_dispatch(participant, msg) } end