pulsar-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 徐建海 <zero...@bytedance.com>
Subject impl of the producer and consumer
Date Sun, 16 Dec 2018 14:34:10 GMT
Hi, users & dev:
    after read the code, I found the msg will be add async inot ledger
in PersistentTopic impl, but how the consumer know the new msg coming? I
can't find any code about this, ashamed about my terrible ability. but
in NonPersistentTopic impl, the msg just go through subscriptions->
subscription -> dispatcher-> consumer->channel. who call show me the
related code in PersistentTopic?

View raw message