Redisson.RDelayedQueue получает задержку долгое время, когда предлагает задачу с отрицательным временем - PullRequest
0 голосов
/ 21 ноября 2018
RedissonClient redissonClient = redisService.getRedissonClient();
RBlockingQueue readyQueue = redissonClient.getBlockingQueue("delay_queue");
RDelayedQueue delayedQueue = redissonClient.getDelayedQueue(readyQueue );
delayedQueue.offer("1111", -2515194, TimeUnit.SECONDS);

Ожидаемое поведение предлагает элемент с временем задержки (-2515194, "2018-11-20 20:00:52"), когда время создания равно "2018-11-20 20:42:08".

Я ожидаю, что он перейдет к readyQueue прямо сейчас.

Фактическое поведение, но через долгое время я получил его из readyQueue на 2018-11-20 21:00:10.Несмотря на то, что я потерял соединение, я не знаю, что приводит к потере соединения паб / суб.

Redisson версия 3.9.0

...