Initial commit of amqp input/output in general working condition.
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.
Merge branch 'features/plugin-restarting' into features/amqp-plugin
Implement reconnect.
Working amqp reconnect with proper wait group and Close handling to avoid closing other connections.
Merge branch 'features/plugin-restarting' into features/amqp-plugin
Usage wait group needed after all.
Merge branch 'features/plugin-restarting' into features/amqp-plugin
Merge branch 'features/plugin-restarting' into features/amqp-plugin
Merge branch 'features/plugin-restarting' into features/amqp-plugin
Add decoders param.
Restructure for input/output to have different configs, initialize them properly.
Allow input to use a set of log line decoders to re-parse the contents of an AMQP message.
Fix restart delay by reseting the current delay as well.
Split AMQP input/output into separate configs, nested structure didn't work for TOML loading.
Use new restart method name for restarting.
Add log line decoder support for AMQP input.
Logfile input was not setting enough fields to qualify messages for serialization.
Add message serialization/deserialization options to AMQP input/output.
Add AMQP input/output docs.
Merge branch 'dev' into features/amqp-plugin

Conflicts:
	pipeline/config.go