PUNSUBSCRIBE

PUNSUBSCRIBE events:*

import Redis from "ioredis";

const subscriber = new Redis(process.env.REDIS_URL!);
await subscriber.psubscribe("events:*");
await subscriber.punsubscribe("events:*");

import { createClient } from "redis";

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

import os
import redis

client = redis.from_url(os.environ["REDIS_URL"])
pubsub = client.pubsub()
pubsub.psubscribe("events:*")
pubsub.punsubscribe("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.PSubscribe(ctx, "events:*")
    if err := pubsub.PUnsubscribe(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.psubscribe(new JedisPubSub() {
    @Override
    public void onPMessage(String pattern, String channel, String message) {
      punsubscribe();
    }
  }, "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.psubscribe("events:*")?;
    pubsub.punsubscribe("events:*")?;
    #[allow(unreachable_code)]
    Ok(())
}