- Fix race condition around connection wait state
- On demand message fetching to prevent local queue blowout
- Ensure custom connection is always killed
- Close remote connection on termination
- Kill connection to server when terminated
- Refactor to isolate connection to ease supervision
- Push received messages via internal signaling
- Transfer messages via internal signal
- Properly cleanup on termination
- Cache signals on source
- Update for latest carnivore
- Include support for auto extraction
- Detect received payload correctly based on adapter
- Fix connection setup when using march_hare
- Move routing key set prior to queue setup
- Add
:publish_tooption to allow publish to exchange instead of queue
- Include option to provide routing key
- Only start message collection if source is receiving
- Parse payload within collector on receipt
- Initial release