-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/7724/
-----------------------------------------------------------
Review request for bookkeeper.
Description
-------
Implement a multiplexing java client.
This addresses bug BOOKKEEPER-368.
https://issues.apache.org/jira/browse/BOOKKEEPER-368
Diffs
-----
hedwig-client/src/main/java/org/apache/hedwig/client/conf/ClientConfiguration.java
fa2c6d6
hedwig-client/src/main/java/org/apache/hedwig/client/handlers/SubscribeResponseHandler.java
b8e5aec
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigClientImpl.java
1724e04
hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/HChannelHandler.java
7753c6e
hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/multiplex/MultiplexHChannelManager.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/multiplex/MultiplexSubscribeResponseHandler.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/multiplex/MultiplexSubscriptionChannelPipelineFactory.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/multiplex/ResubscribeCallback.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/impl/simple/SimpleSubscribeResponseHandler.java
a426a7b
hedwig-protocol/src/main/java/org/apache/hedwig/protocol/PubSubProtocol.java
8d8f2ac
hedwig-protocol/src/main/java/org/apache/hedwig/protoextensions/PubSubResponseUtils.java
af69043
hedwig-protocol/src/main/protobuf/PubSubProtocol.proto 7fafcce
hedwig-server/src/main/java/org/apache/hedwig/server/delivery/FIFODeliveryManager.java
fd5f448
hedwig-server/src/main/java/org/apache/hedwig/server/handlers/SubscribeHandler.java
dfcde9f
hedwig-server/src/main/java/org/apache/hedwig/server/handlers/SubscriptionChannelManager.java
2a8d093
hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ChannelTracker.java
5bfd898
hedwig-server/src/main/java/org/apache/hedwig/server/proxy/HedwigProxy.java
35f8b64
hedwig-server/src/main/java/org/apache/hedwig/server/proxy/ProxyCloseSubscriptionHandler.java
PRE-CREATION
hedwig-server/src/test/java/org/apache/hedwig/client/TestPubSubClient.java
ce0f3f6
hedwig-server/src/test/java/org/apache/hedwig/client/netty/TestCloseSubscription.java
bf74df1
hedwig-server/src/test/java/org/apache/hedwig/client/netty/TestMultiplexing.java
PRE-CREATION
hedwig-server/src/test/java/org/apache/hedwig/server/HedwigRegionTestBase.java
4ec0d50
hedwig-server/src/test/java/org/apache/hedwig/server/delivery/TestThrottlingDelivery.java
4338825
hedwig-server/src/test/java/org/apache/hedwig/server/handlers/TestSubUnsubHandler.java
5bbf603
hedwig-server/src/test/java/org/apache/hedwig/server/integration/TestHedwigHub.java
02b4503
hedwig-server/src/test/java/org/apache/hedwig/server/integration/TestHedwigRegion.java
0b1851e
Diff: https://reviews.apache.org/r/7724/diff/
Testing
-------
Passed all testing.
Thanks,
Sijie Guo
