You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bookkeeper.apache.org by Sijie Guo <gu...@gmail.com> on 2012/10/24 09:27:23 UTC
Review Request: BOOKKEEPER-368: Implementing multiplexing java client.
-----------------------------------------------------------
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