过程ReliableTopic的RingBuffer以相反的顺序(从最新到最旧的)

问题描述 投票:0回答:1

我使用的是ReliableTopic重播最后一个20000个事件和所有后续事件。

首先,这是我用ReliableTopic订阅ReliableMessageListener,我从0方法每次返回retrieveInitialSequence()。这是正确的什么我想达到什么目的?

当我订阅ReliableTopic,我想处理一切,是在以相反的顺序其内部RingBuffer,从最新到最旧。我可以缓冲第一InternalRingBuffer.size()项目,然后扭转这一列表实现这一目标。这依赖于能够获取内部RingBuffer的大小,因为它可能不完整。然而,当我打电话InternalRingBuffer.size()上新连接的情况下,尽管在缓冲区中有是项目,它返回0。这是为什么?如何解决?

hazelcast
1个回答
1
投票

你已经发现了一个错误,我已经创建了以下问题:https://github.com/hazelcast/hazelcast/issues/14468

© www.soinside.com 2019 - 2024. All rights reserved.