You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bookkeeper.apache.org by "jiraposter@reviews.apache.org (Commented) (JIRA)" <ji...@apache.org> on 2012/03/13 12:17:40 UTC

[jira] [Commented] (BOOKKEEPER-168) Message bounding on subscriptions

    [ https://issues.apache.org/jira/browse/BOOKKEEPER-168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13228320#comment-13228320 ] 

jiraposter@reviews.apache.org commented on BOOKKEEPER-168:
----------------------------------------------------------


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/3824/
-----------------------------------------------------------

(Updated 2012-03-13 11:16:09.577984)


Review request for bookkeeper.


Summary
-------

In hedwig, messages for a subscription will queue up forever if the subscriber is offline. In some usecases, this is undesirable, as it will eventually mean resource exhaustion. In this JIRA we propose an optional change to the subscription contract, which allows the user to set a bound on the number of messages which will be queued for its subscription while it is offline.


This addresses bug BOOKKEEPER-168.
    https://issues.apache.org/jira/browse/BOOKKEEPER-168


Diffs (updated)
-----

  hedwig-client/src/main/cpp/inc/hedwig/client.h f37ef98 
  hedwig-client/src/main/cpp/inc/hedwig/subscribe.h 775a32c 
  hedwig-client/src/main/cpp/lib/client.cpp 6d70ad9 
  hedwig-client/src/main/cpp/lib/data.h b4e2c15 
  hedwig-client/src/main/cpp/lib/data.cpp a223120 
  hedwig-client/src/main/cpp/lib/subscriberimpl.h 1cad984 
  hedwig-client/src/main/cpp/lib/subscriberimpl.cpp 32075c4 
  hedwig-client/src/main/cpp/log4cpp.conf 5651e25 
  hedwig-client/src/main/cpp/scripts/log4cxx.conf fc1084c 
  hedwig-client/src/main/cpp/scripts/tester.sh 5df613a 
  hedwig-client/src/main/cpp/test/Makefile.am 62902e6 
  hedwig-client/src/main/cpp/test/main.cpp 3290af3 
  hedwig-client/src/main/cpp/test/messageboundtest.cpp PRE-CREATION 
  hedwig-client/src/main/java/org/apache/hedwig/client/api/Subscriber.java 6910e7d 
  hedwig-client/src/main/java/org/apache/hedwig/client/conf/ClientConfiguration.java 66e049f 
  hedwig-client/src/main/java/org/apache/hedwig/client/data/PubSubData.java 1b33c2f 
  hedwig-client/src/main/java/org/apache/hedwig/client/netty/HedwigSubscriber.java 5fb1d88 
  hedwig-protocol/src/main/java/org/apache/hedwig/protocol/PubSubProtocol.java f46868b 
  hedwig-protocol/src/main/protobuf/PubSubProtocol.proto e44d981 
  hedwig-server/src/main/java/org/apache/hedwig/server/delivery/FIFODeliveryManager.java 2c9af4d 
  hedwig-server/src/main/java/org/apache/hedwig/server/persistence/BookkeeperPersistenceManager.java f1fd965 
  hedwig-server/src/main/java/org/apache/hedwig/server/persistence/LocalDBPersistenceManager.java 02ec607 
  hedwig-server/src/main/java/org/apache/hedwig/server/persistence/PersistenceManager.java 5c38ad9 
  hedwig-server/src/main/java/org/apache/hedwig/server/persistence/ReadAheadCache.java 0261521 
  hedwig-server/src/main/java/org/apache/hedwig/server/regions/HedwigHubSubscriber.java 40aa338 
  hedwig-server/src/main/java/org/apache/hedwig/server/subscriptions/AbstractSubscriptionManager.java 714a631 
  hedwig-server/src/test/java/org/apache/hedwig/server/persistence/MessageBoundedPersistenceTest.java PRE-CREATION 
  hedwig-server/src/test/java/org/apache/hedwig/server/persistence/StubPersistenceManager.java 84b866d 

Diff: https://reviews.apache.org/r/3824/diff


Testing
-------


Thanks,

Ivan


                
> Message bounding on subscriptions
> ---------------------------------
>
>                 Key: BOOKKEEPER-168
>                 URL: https://issues.apache.org/jira/browse/BOOKKEEPER-168
>             Project: Bookkeeper
>          Issue Type: New Feature
>            Reporter: Ivan Kelly
>            Assignee: Ivan Kelly
>             Fix For: 4.1.0
>
>         Attachments: BOOKKEEPER-168.diff, BOOKKEEPER-168.diff, BOOKKEEPER-168.diff
>
>
> In hedwig, messages for a subscription will queue up forever if the subscriber is offline. In some usecases, this is undesirable, as it will eventually mean resource exhaustion. In this JIRA we propose an optional change to the subscription contract, which allows the user to set a bound on the number of messages which will be queued for its subscription while it is offline.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira