How to use JedisCluster pub/sub in 4.0.1 jedis library?

[sodrulamin]

I am trying to update jedis library to latest(4.0.1) one. But in this latest library I think the subscribe method has been shifted to JedisPubSub class or I am not sure where.

But now I can't find any working example of pub/sub module for cluster. I have so far tried,

    ```

//pool configuration
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig<>();
poolConfig.setMinIdle(5);
poolConfig.setMaxIdle(100);
poolConfig.setMaxWait(Duration.ofMillis(5000));

    //jedis configuration
    JedisClientConfig jedisClientConfig = DefaultJedisClientConfig.builder()
            .password(config.getRedisPassword())
            .ssl(false)
            .build();

    //host and port
    HostAndPort hostAndPort = new HostAndPort(config.getRedisHost(), config.getRedisPort());

    ConnectionPool connectionPool = new ConnectionPool(hostAndPort, jedisClientConfig, poolConfig);
    Connection connection = connectionPool.getResource();

    //create a jedis pub sub instance
    JedisPubSub pubSub = new JedisPubSub() {
        @Override
        public void onMessage(String channel, String message) {
            super.onMessage(channel, message);
        }

        @Override
        public void onPMessage(String pattern, String channel, String message) {
            super.onPMessage(pattern, channel, message);
        }

        @Override
        public void onSubscribe(String channel, int subscribedChannels) {
            super.onSubscribe(channel, subscribedChannels);
        }

        @Override
        public void onUnsubscribe(String channel, int subscribedChannels) {
            super.onUnsubscribe(channel, subscribedChannels);
        }

        @Override
        public void onPUnsubscribe(String pattern, int subscribedChannels) {
            super.onPUnsubscribe(pattern, subscribedChannels);
        }

        @Override
        public void onPSubscribe(String pattern, int subscribedChannels) {
            super.onPSubscribe(pattern, subscribedChannels);
        }

        @Override
        public void onPong(String pattern) {
            super.onPong(pattern);
        }
    };
    
    pubSub.proceed(connection, "test");

But getting error that says

> redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketTimeoutException: Read timed out at redis.clients.jedis.util.RedisInputStream.ensureFill(RedisInputStream.java:204) at redis.clients.jedis.util.RedisInputStream.readByte(RedisInputStream.java:42) at redis.clients.jedis.Protocol.process(Protocol.java:126) at redis.clients.jedis.Protocol.read(Protocol.java:192) at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:316) at redis.clients.jedis.Connection.getUnflushedObjectMultiBulkReply(Connection.java:282) at redis.clients.jedis.JedisPubSub.process(JedisPubSub.java:131) at redis.clients.jedis.JedisPubSub.proceed(JedisPubSub.java:124) at switchbalancetest.Test.jedisUpdateTest(Test.java:78) at switchbalancetest.Test.main(Test.java:40) Caused by: java.net.SocketTimeoutException: Read timed out at java.net.SocketInputStream.socketRead0(Native Method) at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) at java.net.SocketInputStream.read(SocketInputStream.java:171) at java.net.SocketInputStream.read(SocketInputStream.java:141) at java.net.SocketInputStream.read(SocketInputStream.java:127) at redis.clients.jedis.util.RedisInputStream.ensureFill(RedisInputStream.java:198) ... 9 more

And in redis server log I found error that says,

> Bad message length or signature received from Cluster bus.

In current library, I thought subscribe method should be available under [UnifiedJedis ](https://javadoc.io/static/redis.clients/jedis/4.0.1/redis/clients/jedis/UnifiedJedis.html) Class. But, I can't find it there. How can I successfully do this ?