We are using Service Stack's RedisClient's BlockingDequeue to persist some data until it can be processed. The calling code looks like
using (var client = ClientPool.GetClient())
return client.As<TMessage>().Lists[_channel].BlockingDequeue(timeout);
If the server hosting Redis is restarted, the connections for the BlockingDequeue go zombie and never return until the client application is restarted.
We have tried setting the timeout on the BlockingDequeue as well as the PooledConnectionManager but neither helped, I am guessing because the timeout is enforced on the server side.
Is this type of fault tolerance built into service stack and we are missing it?
Or is it something that our implementation should handle? If so are there any recommended approaches?