You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
The text was updated successfully, but these errors were encountered:
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.
The text was updated successfully, but these errors were encountered: