Bug-RedisBroadcastManager-v2.7.0.M1

[jxplus]

    @Override
    public CacheResult publish(CacheMessage message) {
        Object jedisObj = null;
        try {
            jedisObj = writeCommands();
           // error line
            byte[] value = config.getValueEncoder().apply(message);
            if (jedisObj instanceof Jedis) {
                ((Jedis) jedisObj).publish(channel, value);
            } else {
                ((UnifiedJedis) jedisObj).publish(channel, value);
            }
            return CacheResult.SUCCESS_WITHOUT_MSG;
        } catch (Exception ex) {
            logError("PUBLISH", "N/A", ex);
            return new CacheResult(ex);
        } finally {
            closeJedis(jedisObj);
        }
    }

RedisBroadcastManager中上面这个方法，config.getValueEncoder().apply(message);这个报错，ParseFunction的apply()方法没有实现的。
这里我看是ExternalCacheAutoInit里设置的。

[areyouok]

fixed

[areyouok]

如果还有问题，可重新打开

[jxplus]

@areyouok 只是替换keyConvertor不够吧，还得换掉valueDecoder。用经过cacheContext处理过的cache对象，或者直接用configProvider转换都行好像。
另外，这个RedisBroadcastManager里的runSubThread()方法，无限循环一直在创建新连接，感觉不用循环吧，调一次subscribe不就够了吗？

[areyouok]

只做缓存失效，所以通知消息里面不传递value。

subscribe是堵塞的，如果不发生异常，不会不停的创建，放在循环里面是为了做异常兜底。

[jxplus]

有道理

[jxplus]

不过我本地试的时候，subscribe会报错，报错内容是该channel已经subscribe，我使用的是connectionFactory.getConnection().subscribe()

[jxplus]

value不传递的问题，貌似只是要复用jetcache的序列化，来序列化CacheMessage对象，对象的value属性确实是null的，所以还是需要使用到ValueEncoder和Decoder。

[areyouok]

你说的对，我看花了