Как отписаться от канала с помощью "New Managed Pub/Sub Server" в Servicestack.Redis
В документах New Managed Pub/Sub Server они показали, как подписаться на каналы при инициализации сервера pubsubserver. Но тогда как вы отписываетесь от определенного канала позже в программе, когда это необходимо?
МОЙ КОД:
using ServiceStack.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
namespace va.communication
{
class Program
{
static void Main(string[] args)
{
var clientsManager = new PooledRedisClientManager();
//subscribe to channels 'messages' and 'queue'
var redisPubSub = new RedisPubSubServer(clientsManager, "messages","queue")
{
OnUnSubscribe = (channel) =>
{
Console.WriteLine("Unsubscribed from channel '{0}'", channel);
},
OnMessage = (channel, msg) =>
{
Console.WriteLine("Received '{0}' from channel '{1}'", msg, channel);
}
};
redisPubSub.Start();
//...
//other code which takes ~5s after which i want to unsubscribe from 'messages'
Thread.Sleep(5000);
//...
//no longer require channel 'messages'. what to do here?
while (true) ;//continue with other code
}
}
}
2 ответа
Решение
Вызов Stop() или Dispose() отменит подписку и прекратит прослушивание подписанных каналов. Используйте Stop(), если вы хотите начать прослушивание позже, или Dispose(), если вы закончили с RedisPubSubManager.
Благодаря mythz и некоторым исследованиям это сработало для меня:
чтобы отписаться от "сообщений" используйте это->
//reassign channels to just 'queue' removing 'messages' as a channel
redisPubSub.Channels = new string[] {"queue" };
чтобы отписаться от всех каналов используйте это->
redisPubSub.Channels = new string[] { };//empty channel array