Seppuku

Track error occurrences and shutdown service instance once a defined number of unique messages have errors in a defined time period.
Not sure it matters much, but on the emque-producing side it goes

Emque::Producing::Publisher::RabbitMq
Emque::Producing::Publisher::Kafka

while on the consuming side it goes 

Emque::Consuming::RabbitMq::Manager
Emque::Consuming::Kafka::Manager

it'd been nagging at me, so since you're cleaning up the adapter bits, thought I'd get your take on it?