Initial commit of amqp input/output in general working condition.
Fix condition where captures could be a nil rather than an empty map.
Merge branch 'dev' into features/amqp-plugin
Better connection closing, by counting how many channels are outstanding.
Remove unneeded ticker as channel closing is sufficient.
Properly break the loop rather than return to ensure the connection is cleaned up.
First pass at converting TransformFilter into LoglineDecoder.
Add initial restarting loop.
Ensure all the wrappers are available as we may need to recreate plugins later if they fail during runtime.
Reinitialize the plugin upon its death with a newly created one in a loop.
Add a log message so its easy to see that the runner is restarting the plugin.
Merge branch 'features/plugin-restarting' into features/amqp-plugin
Implement reconnect.
Move generally useful MessageTemplate type and InterpolateString function to
decoders.py for better visibility.
Fixup LoglineInput test for new decoder usage.
Added initial LoglineDecoder test.
Working amqp reconnect with proper wait group and Close handling to avoid closing other connections.
Ensure we handle plugin creation failures, catch them, and retry with the sleep until we're sleeping or have succeeded.
Merge branch 'features/plugin-restarting' into features/amqp-plugin
Usage wait group needed after all.
Add input runner restarting, change min reconnect period to half a second.