lib/ruote/svc/dispatch_pool.rb
# Wraps the call to do_dispatch in a thread.
#
Wraps the call to do_dispatch in a thread.
Wraps the call to do_dispatch in a thread .
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
def do_threaded_dispatch ( participant , msg ) msg = Rufus :: Json . dup ( msg ) Thread . new { do_dispatch ( participant , msg ) } end
Wraps the call to do_dispatch in a thread.
Wraps the call to do_dispatch in a thread .
# # 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
participant
msg