Как отписаться от канала с помощью "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
Другие вопросы по тегам