mirror of
https://github.com/logos-messaging/specs.git
synced 2026-01-02 14:13:06 +00:00
chore: more rephrasing
This commit is contained in:
parent
8f7fb86f38
commit
5f0d5f8d2e
@ -106,11 +106,10 @@ An application could use different pubsub topics and content topics, for example
|
||||
|
||||
For incoming messages, the processing flow can be like this:
|
||||
- subscribe to the interested pubsub and content topics
|
||||
- query the store node with the interested topics and time range for message hashes periodically
|
||||
- periodically query the store node with the interested topics and time range for message hashes
|
||||
- check if each received message hash already exists in the local database. if not, add the missing message hash to a buffer.
|
||||
- batch fetch the full messages corresponding to the missing message hashes in the buffer from the store node
|
||||
- process the messages
|
||||
- update the last fetch time for the interested topic
|
||||
|
||||
The implementation in Python may look like this:
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user