You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/11/18 06:11:26 UTC
[pulsar] branch master updated (f5a1642 -> 2a183ab)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from f5a1642 Update #! in shell scripts (#8076)
add 2a183ab Make ServerCnx, Producer and Consumer independent of Netty (#6720)
No new revisions were added by this update.
Summary of changes:
.../pulsar/broker/service/BrokerService.java | 4 +-
.../org/apache/pulsar/broker/service/Consumer.java | 122 +++------------------
.../org/apache/pulsar/broker/service/Producer.java | 56 +++++-----
.../broker/service/PulsarChannelInitializer.java | 2 +-
.../pulsar/broker/service/PulsarCommandSender.java | 16 ++-
.../broker/service/PulsarCommandSenderImpl.java | 105 ++++++++++++++++++
.../apache/pulsar/broker/service/ServerCnx.java | 39 ++++++-
.../org/apache/pulsar/broker/service/Topic.java | 2 +-
.../apache/pulsar/broker/service/TransportCnx.java | 80 ++++++++++++++
.../service/nonpersistent/NonPersistentTopic.java | 6 +-
.../broker/service/persistent/PersistentTopic.java | 10 +-
.../service/MessagePublishBufferThrottleTest.java | 23 ++--
.../PersistentDispatcherFailoverConsumerTest.java | 4 +
.../pulsar/broker/service/PersistentTopicTest.java | 2 +
14 files changed, 310 insertions(+), 161 deletions(-)
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TransportCnx.java