Refactor tasks to take and use a config dict.
Inspect for required config and fix 'else' syntax
Add drain method that removes the task's events and unlocks the task to run again.
Switch to task.drain() method. Add debug outpu. Replace missing 'socket' import.
Rename CloudKick to HTTPJSON
Update Riemann-sumd version, add install_requires
Add dependenices for setup.cfg
Only instantiate queue once per class - we can reuse it