proper (re-)connection handing for AMQP inputs. fixes #385