UNSUBSCRIBE

UNSUBSCRIBE events

import Redis from "ioredis";

const subscriber = new Redis(process.env.REDIS_URL!);
await subscriber.subscribe("events");
await subscriber.unsubscribe("events");

import { createClient } from "redis";

const subscriber = await createClient({ url: process.env.REDIS_URL }).connect();
await subscriber.subscribe("events", console.log);
await subscriber.unsubscribe("events");

import os
import redis

client = redis.from_url(os.environ["REDIS_URL"])
pubsub = client.pubsub()
pubsub.subscribe("events")
pubsub.unsubscribe("events")

package main

import (
    "context"
    "fmt"
    "os"

    "github.com/redis/go-redis/v9"
)

func main() {
    ctx := context.Background()
    opts, err := redis.ParseURL(os.Getenv("REDIS_URL"))
    if err != nil {
        panic(err)
    }
    client := redis.NewClient(opts)
    pubsub := client.Subscribe(ctx, "events")
    if err := pubsub.Unsubscribe(ctx, "events"); err != nil {
        panic(err)
    }
}

import java.net.URI;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

try (Jedis jedis = new Jedis(new URI(System.getenv("REDIS_URL")))) {
  jedis.subscribe(new JedisPubSub() {
    @Override
    public void onMessage(String channel, String message) {
      unsubscribe();
    }
  }, "events");
}

fn main() -> redis::RedisResult<()> {
    let url = std::env::var("REDIS_URL").expect("REDIS_URL is not set");
    let client = redis::Client::open(url)?;
    let mut connection = client.get_connection()?;
    let mut pubsub = connection.as_pubsub();
    pubsub.subscribe("events")?;
    pubsub.unsubscribe("events")?;
    #[allow(unreachable_code)]
    Ok(())
}