Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | only retain ram msgs when inserting into pending_ackbug25373 | Matthias Radestock | 2013-01-02 | 1 | -27/+24 |
| | | | | which keeps memory use constant during fetch operations | ||||
* | refactor: return less from vq:remove | Matthias Radestock | 2013-01-02 | 1 | -14/+14 |
| | |||||
* | Merged bug25372 | Emile Joubert | 2013-01-02 | 5 | -45/+42 |
|\ | |||||
| * | drop IsDelivered from bq:{fetchwhile,ackfold}bug25372 | Matthias Radestock | 2013-01-01 | 4 | -22/+18 |
| | | | | | | | | since we don't need it | ||||
| * | replace bq:foreach_ack with a more versatile ackfold | Matthias Radestock | 2013-01-01 | 5 | -34/+35 |
| | | |||||
* | | refactor: rename vq:intern_fetch to 'remove' | Matthias Radestock | 2013-01-02 | 1 | -18/+18 |
| | | |||||
* | | cosmetic | Matthias Radestock | 2013-01-02 | 1 | -1/+1 |
| | | |||||
* | | cosmetic | Matthias Radestock | 2013-01-02 | 1 | -6/+5 |
| | | |||||
* | | cosmetic | Matthias Radestock | 2013-01-01 | 1 | -2/+2 |
| | | |||||
* | | refactor: rename drop_expired_messages to drop_expired_msgs | Matthias Radestock | 2013-01-01 | 1 | -7/+7 |
|/ | |||||
* | cosmetic | Matthias Radestock | 2012-12-29 | 1 | -6/+3 |
| | |||||
* | refactor: shorter/better names for rabbit_trace functions | Matthias Radestock | 2012-12-28 | 3 | -13/+11 |
| | |||||
* | stable to default | Simon MacMullen | 2012-12-12 | 3 | -18/+21 |
|\ | |||||
| * | Merge bug25353 | Simon MacMullen | 2012-12-12 | 1 | -18/+12 |
| |\ | |||||
| | * | Reminder | Simon MacMullen | 2012-12-12 | 1 | -0/+2 |
| | | | |||||
| | * | make sure the stats and rate timers don't keep each other alive | Matthias Radestock | 2012-12-11 | 1 | -18/+10 |
| |/ | |||||
| * | Merge heads | Simon MacMullen | 2012-12-11 | 2 | -0/+9 |
| |\ | |||||
| | * | Changelogs for 3.0.1. | Simon MacMullen | 2012-12-11 | 2 | -0/+9 |
| | | | |||||
| * | | Added tag rabbitmq_v3_0_1 for changeset 91df77f12b7f | Simon MacMullen | 2012-12-10 | 0 | -0/+0 |
| |/ | |||||
| * | Removed tag rabbitmq_v3_0_1rabbitmq_v3_0_1 | Simon MacMullen | 2012-12-10 | 0 | -0/+0 |
| | | |||||
* | | merge stable into default | Matthias Radestock | 2012-12-10 | 1 | -4/+7 |
|\ \ | |/ | |||||
| * | merge bug25351 into stable | Matthias Radestock | 2012-12-10 | 1 | -4/+7 |
| |\ | |||||
| | * | Those catches do no really do anything.bug25351 | Simon MacMullen | 2012-12-10 | 1 | -2/+2 |
| | | | |||||
| | * | Call application_master:get_child/1 more like OTP does. | Simon MacMullen | 2012-12-10 | 1 | -2/+3 |
| | | | |||||
| | * | application_controller:get_master/1 can return 'undefined'. | Simon MacMullen | 2012-12-10 | 1 | -4/+6 |
| |/ | |||||
| * | Added tag rabbitmq_v3_0_1 for changeset d538aa1bb716 | Simon MacMullen | 2012-12-07 | 0 | -0/+0 |
| | | |||||
| * | Remove spurious 3.0.1 changelogs. | Simon MacMullen | 2012-12-07 | 2 | -9/+0 |
| | | |||||
| * | Added tag rabbitmq_v3_0_1 for changeset 43f92e93c7d0 | Simon MacMullen | 2012-12-06 | 0 | -0/+0 |
| | | |||||
| * | Package changelogs for 3.0.1. | Simon MacMullen | 2012-12-06 | 2 | -0/+9 |
| | | |||||
* | | Fix a couple of partition-related specs. | Simon MacMullen | 2012-12-10 | 2 | -2/+3 |
| | | |||||
* | | fix spec bugs | Matthias Radestock | 2012-12-06 | 1 | -5/+5 |
| | | |||||
* | | Merged stable into default | Emile Joubert | 2012-12-05 | 12 | -388/+607 |
|\ \ | |/ |/| | |||||
| * | merge stable into default | Matthias Radestock | 2012-12-05 | 2 | -3/+17 |
| |\ | |||||
| * \ | stable to default | Simon MacMullen | 2012-12-04 | 12 | -388/+607 |
| |\ \ | |||||
| | * | | remove pre-0-9-1 cruft | Matthias Radestock | 2012-12-04 | 1 | -8/+4 |
| | | | | |||||
| | * | | Merged bug25328 | Emile Joubert | 2012-12-04 | 6 | -68/+123 |
| | |\ \ | |||||
| | | * | | yet more testsbug25328 | Matthias Radestock | 2012-12-03 | 1 | -2/+21 |
| | | | | | |||||
| | | * | | test more | Matthias Radestock | 2012-12-03 | 1 | -9/+13 |
| | | | | | |||||
| | | * | | add test for vq:fetchwhile | Matthias Radestock | 2012-12-03 | 1 | -11/+20 |
| | | | | | |||||
| | | * | | Whitespace | Emile Joubert | 2012-12-03 | 1 | -1/+1 |
| | | | | | |||||
| | | * | | merge default into bug25328 | Matthias Radestock | 2012-11-30 | 6 | -58/+81 |
| | | |\ \ | | |/ / / | |||||
| | | * | | merge default into bug25328 | Matthias Radestock | 2012-11-30 | 6 | -58/+81 |
| | | |\ \ | |||||
| | | | * | | return to a simpler, better BQ:dropwhile, and introduce 'fetchwhile' | Matthias Radestock | 2012-11-29 | 6 | -64/+87 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...to cover the remaining required functionality, including the ability to process messages along the way, pass around an accumulator, and get hold of the IsDelivered flag (not needed in our use case but included for similarity with 'fetch'). | ||||
| | * | | | | unbreak qc (hopefully) | Matthias Radestock | 2012-11-30 | 1 | -2/+2 |
| | |/ / / | |||||
| | * | | | remove unused state var | Matthias Radestock | 2012-11-30 | 1 | -29/+14 |
| | |/ / | | | | | | | | | | | | | | | | | We were diligently maintaining ack_msg_id, but never actually using it for anything. And it's always been like that. | ||||
| | * | | merge bug25303 into default | Matthias Radestock | 2012-11-28 | 14 | -274/+269 |
| | |\ \ | |||||
| | | * \ | re-merge bug25303 into default | Matthias Radestock | 2012-11-27 | 14 | -274/+269 |
| | | |\ \ | |||||
| | | | * \ | Merge bug25323 | Simon MacMullen | 2012-11-27 | 7 | -57/+40 |
| | | | |\ \ | |||||
| | | | | * | | mark all messages enqueued in the slave as 'delivered'bug25323 | Matthias Radestock | 2012-11-26 | 7 | -57/+40 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | which is a much better than the set_delivered logic, which we can now get rid of. In doing so it also becomes clear that having the 'delivered' flag in the #message_properties is less than ideal. It is mutable and we never bothered updating vq s.t. it sets the flag correctly. So lets get rid of it and add a parameter to bq:publish instead | ||||
| | | | * | | | cosmetic | Matthias Radestock | 2012-11-27 | 1 | -5/+3 |
| | | | | | | |