Блог

Я использую последнюю стабильную версию Redis и клиент 3.0.1 (я также пробовал 2.8.1) в Maven. Соединение хорошее, если я меняю адрес на плохой, то это ошибка (исправно). Эта команда работает в консоли redis. Но если я использую ее в приложении в новом потоке или для одноразового использования, это зависающее приложение (нулевая ошибка, но приложение не отвечает). Почему это не работает? Как это исправить?

 <dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.0.1</version>
</dependency>
  

 new Jedis("localhost", 6379, 10000).subscribe(new JedisPubSub() {
    @Override
    public void onMessage(String channel, String message) {
        System.out.println(channel   message);
    }

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

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

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

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

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

}, "test");