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