Class Ruote::DispatchPool
In: lib/ruote/svc/dispatch_pool.rb
Parent: Object

The class where despatchement of workitems towards [real] participant is done.

Can be extended/replaced for better handling of Thread (why not something like a thread pool or no threads at all).

Methods

Public Class methods

Public Instance methods

Protected Instance methods

Dispatching the msg.

Instantiates the participant and calls its cancel method.

Instantiates the participant and calls its on_pause (or on_resume) method.

dispatch_resume(msg)

Alias for dispatch_pause

The raw dispatch work, wrapped in error handling.

Returns true if the participant doesn‘t want the consume to happen in a new Thread.

The actual dispatching (call to Participant#consume or on_workitem).

No error rescuing so it might be interesting for some extension classes (like in ruote-swf).

[Validate]