Commit 61f9c3a8 authored by Nick Craver's avatar Nick Craver

This moves us back to GetGridge() working

Still needs fixing, but sanity checking this is the issue with some subscription tests. The flags change is a bit more invovled, not sure whether to switch to Message passing, or add Flags usages in some cases.
parent aa72566e
......@@ -247,12 +247,13 @@ internal void KeepAlive()
msg.SetSource(ResultProcessor.Tracer, null);
break;
case ConnectionType.Subscription:
if (commandMap.IsAvailable(RedisCommand.PING) && features.PingOnSubscriber)
{
msg = Message.Create(-1, CommandFlags.FireAndForget, RedisCommand.PING);
msg.SetSource(ResultProcessor.Tracer, null);
}
else if (commandMap.IsAvailable(RedisCommand.UNSUBSCRIBE))
//if (commandMap.IsAvailable(RedisCommand.PING) && features.PingOnSubscriber)
//{
// msg = Message.Create(-1, CommandFlags.FireAndForget, RedisCommand.PING);
// msg.SetSource(ResultProcessor.Tracer, null);
//}
//else
if (commandMap.IsAvailable(RedisCommand.UNSUBSCRIBE))
{
msg = Message.Create(-1, CommandFlags.FireAndForget, RedisCommand.UNSUBSCRIBE,
(RedisChannel)Guid.NewGuid().ToByteArray());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment