Open coreyauger opened 8 years ago
I would like to have a common base for akka consumers... to allow for a generic way to process clean-up
ex: private[this] val consumerRegistry = new ConcurrentHashMap[String, AkkaConsumerBase[String, _]] `
private[this] val consumerRegistry = new ConcurrentHashMap[String, AkkaConsumerBase[String, _]]
def shutdown() = { logger.info("Shutting down Event Bus") producer.close() Await.ready(Future.sequence(consumerRegistry.map(e => e._2.stop())), 5 minute) }
Thoughts ?
seems legit, want to do a PR?
Sounds good :)
I would like to have a common base for akka consumers... to allow for a generic way to process clean-up
ex:
private[this] val consumerRegistry = new ConcurrentHashMap[String, AkkaConsumerBase[String, _]]
`Thoughts ?