Redis
 sql >> Base de données >  >> NoSQL >> Redis

Redis Pub/Sub ServiceStack, annulation du thread

Un exemple qui montre comment s'abonner et se désabonner des messages est dans RedisMqServer, par exemple :

using (var subscription = redisClient.CreateSubscription())
{
    subscription.OnUnSubscribe = channel => 
        Log.Debug("OnUnSubscribe: " + channel);

    subscription.OnMessage = (channel, msg) =>
    {
        if (msg == "STOP")
        {
            Log.Debug("Stop Command Issued");
            Log.Debug("Unsubscribing from all Channels...");
            subscription.UnSubscribeFromAllChannels(); //Unblocks thread.
        }
    };

    subscription.SubscribeToChannels(QueueNames.TopicIn); //blocks thread
}

Où il utilise un message de contrôle personnalisé pour débloquer le fil d'arrière-plan et se désabonner de tous les canaux de l'abonnement OnMessage gestionnaire.