EM Pipelines

TODO

• Make wiring easier
• Example apps
• Control flow for AmqpEventSource
• Evented I/O for IOEventSource
• Consolidate logger and monitoring
• Default monitoring implementation
• Performance testing
• Detect insonsistency when handler didnt consume or pass message ahead