I've created a consumer and a producer, and had to jump through some hoops to get the process to close. I ended up having to:
Create a NIOEventLoopGroup, and add it to an NSQConfig that was passed to each producer/consumer, and had to pass it a thread factory that would create daemon threads (shutdown on the object didn't seem to work)
Create an executor service with a similar thread factory that creates daemon threads, and pass that to consumers only (producers shut theirs down properly)
It would be nice if this were either easier to do, or documented.
I've created a consumer and a producer, and had to jump through some hoops to get the process to close. I ended up having to:
It would be nice if this were either easier to do, or documented.