Closed qqeasonchen closed 2 months ago
I want to try it. Can you tell me where to start?
@jevinjiang The existing standalone
storage-plugin used a BlockingQueue as Event Store
in EventMesh Runtime JVM memory. We'd like to use disrupter to substitue BlockingQueue.
@Pil0tXia thank you~ Let me confirm what I need to do: Replacing org.apache.eventmesh.storage.standalone.broker.MessageQueue(BlockingQueue) with disruptor in standalone storage-plugin
I have a question while modifying the MessageQueue. If there are no subscribers, can I create a MessageQueue to store messages? 我有一个疑问, 如果说一个messageQueue不存在订阅者,我应该创建它吗
I think disruptor is not suitable for long-term storage of events。
while modifying the MessageQueue. If there are no subscribers, can I create a MessageQueue to store messages?
The ideal relationship between producer, MessageQueue, and consumer is one-to-one-to-one. A consumer cannot subscribe to or retrieve messages from a non-existent MessageQueue. If the consumer declares the queue, there is a potential risk of discarding messages sent by the producer before declaring the queue. After a producer creates a new MessageQueue, you need to ensure that there is a corresponding consumer subscribing to this queue.
I think disruptor is not suitable for long-term storage of events
Messages stored in standalone mode will be lost after a reboot. This is acceptable.
Search before asking
Feature Request
Support disruptor[1] as memory queue, for event processing.
Are you willing to submit PR?
Code of Conduct