You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/22 19:14:31 UTC
[pulsar] branch master updated (bf06ef3 -> cb34e6a)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from bf06ef3 [schema] AutoConsume should use the schema associated with messages as both writer and reader schema (#4325)
add cb34e6a Moved entries filtering from consumer to dispatcher (#4329)
No new revisions were added by this update.
Summary of changes:
.../broker/service/AbstractBaseDispatcher.java | 96 +++++++++++
.../AbstractDispatcherMultipleConsumers.java | 11 +-
.../AbstractDispatcherSingleActiveConsumer.java | 5 +-
.../org/apache/pulsar/broker/service/Consumer.java | 185 +++++----------------
.../pulsar/broker/service/EntryBatchSizes.java | 58 +++++++
.../{Replicator.java => SendMessageInfo.java} | 42 +++--
.../NonPersistentDispatcherMultipleConsumers.java | 16 +-
...onPersistentDispatcherSingleActiveConsumer.java | 16 +-
.../PersistentDispatcherMultipleConsumers.java | 32 ++--
.../PersistentDispatcherSingleActiveConsumer.java | 73 ++++----
...istentStickyKeyDispatcherMultipleConsumers.java | 37 +++--
.../service/persistent/PersistentSubscription.java | 8 +-
.../PersistentDispatcherFailoverConsumerTest.java | 12 +-
.../pulsar/broker/service/PersistentTopicTest.java | 4 +-
.../org/apache/pulsar/common/api/Commands.java | 32 ++++
15 files changed, 380 insertions(+), 247 deletions(-)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/EntryBatchSizes.java
copy pulsar-broker/src/main/java/org/apache/pulsar/broker/service/{Replicator.java => SendMessageInfo.java} (55%)