-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/7129/
-----------------------------------------------------------
Review request for bookkeeper.
Description
-------
Currently Hedwig client is coupled with the design of one subscription per
channel. In order to multiplex multiple subscription into one channel, it would
be better to refine the Hedwig java client code to provide better interface to
support both mode.
This addresses bug BOOKKEEPER-364.
https://issues.apache.org/jira/browse/BOOKKEEPER-364
Diffs
-----
hedwig-client/src/main/java/org/apache/hedwig/client/data/MessageConsumeData.java
ccb9903
hedwig-client/src/main/java/org/apache/hedwig/client/handlers/AbstractResponseHandler.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/handlers/MessageConsumeCallback.java
d8f9324
hedwig-client/src/main/java/org/apache/hedwig/client/handlers/PublishResponseHandler.java
d83078e
hedwig-client/src/main/java/org/apache/hedwig/client/handlers/SubscribeReconnectCallback.java
f746803
hedwig-client/src/main/java/org/apache/hedwig/client/handlers/SubscribeResponseHandler.java
ac209d1
hedwig-client/src/main/java/org/apache/hedwig/client/handlers/UnsubscribeResponseHandler.java
f77417f
hedwig-client/src/main/java/org/apache/hedwig/client/netty/AbstractHChannelManager.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/CleanupChannelMap.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/ClientChannelPipelineFactory.java
ca6d706
hedwig-client/src/main/java/org/apache/hedwig/client/netty/ConnectCallback.java
68867a3
hedwig-client/src/main/java/org/apache/hedwig/client/netty/DefaultServerChannel.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/FilterableMessageHandler.java
a97bab9
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HChannel.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HChannelHandler.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HChannelImpl.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HChannelManager.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigClientImpl.java
39d9a86
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigPublisher.java
0891945
hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigSubscriber.java
81af1dd
hedwig-client/src/main/java/org/apache/hedwig/client/netty/NetUtils.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/NonSubscriptionChannelPipelineFactory.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/ResponseHandler.java
127cfb8
hedwig-client/src/main/java/org/apache/hedwig/client/netty/SubscriptionEventEmitter.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/WriteCallback.java
41a19d2
hedwig-client/src/main/java/org/apache/hedwig/client/netty/package-info.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/simple/SimpleHChannelManager.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/simple/SimpleSubscribeResponseHandler.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/simple/SimpleSubscriptionChannelPipelineFactory.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/client/netty/simple/SubscribeReconnectCallback.java
PRE-CREATION
hedwig-client/src/main/java/org/apache/hedwig/util/VarArgs.java PRE-CREATION
Diff: https://reviews.apache.org/r/7129/diff/
Testing
-------
Thanks,
Sijie Guo
