summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* only retain ram msgs when inserting into pending_ackbug25373Matthias Radestock2013-01-021-27/+24
| | | | which keeps memory use constant during fetch operations
* refactor: return less from vq:removeMatthias Radestock2013-01-021-14/+14
|
* Merged bug25372Emile Joubert2013-01-025-45/+42
|\
| * drop IsDelivered from bq:{fetchwhile,ackfold}bug25372Matthias Radestock2013-01-014-22/+18
| | | | | | | | since we don't need it
| * replace bq:foreach_ack with a more versatile ackfoldMatthias Radestock2013-01-015-34/+35
| |
* | refactor: rename vq:intern_fetch to 'remove'Matthias Radestock2013-01-021-18/+18
| |
* | cosmeticMatthias Radestock2013-01-021-1/+1
| |
* | cosmeticMatthias Radestock2013-01-021-6/+5
| |
* | cosmeticMatthias Radestock2013-01-011-2/+2
| |
* | refactor: rename drop_expired_messages to drop_expired_msgsMatthias Radestock2013-01-011-7/+7
|/
* cosmeticMatthias Radestock2012-12-291-6/+3
|
* refactor: shorter/better names for rabbit_trace functionsMatthias Radestock2012-12-283-13/+11
|
* stable to defaultSimon MacMullen2012-12-123-18/+21
|\
| * Merge bug25353Simon MacMullen2012-12-121-18/+12
| |\
| | * ReminderSimon MacMullen2012-12-121-0/+2
| | |
| | * make sure the stats and rate timers don't keep each other aliveMatthias Radestock2012-12-111-18/+10
| |/
| * Merge headsSimon MacMullen2012-12-112-0/+9
| |\
| | * Changelogs for 3.0.1.Simon MacMullen2012-12-112-0/+9
| | |
| * | Added tag rabbitmq_v3_0_1 for changeset 91df77f12b7fSimon MacMullen2012-12-100-0/+0
| |/
| * Removed tag rabbitmq_v3_0_1rabbitmq_v3_0_1Simon MacMullen2012-12-100-0/+0
| |
* | merge stable into defaultMatthias Radestock2012-12-101-4/+7
|\ \ | |/
| * merge bug25351 into stableMatthias Radestock2012-12-101-4/+7
| |\
| | * Those catches do no really do anything.bug25351Simon MacMullen2012-12-101-2/+2
| | |
| | * Call application_master:get_child/1 more like OTP does.Simon MacMullen2012-12-101-2/+3
| | |
| | * application_controller:get_master/1 can return 'undefined'.Simon MacMullen2012-12-101-4/+6
| |/
| * Added tag rabbitmq_v3_0_1 for changeset d538aa1bb716Simon MacMullen2012-12-070-0/+0
| |
| * Remove spurious 3.0.1 changelogs.Simon MacMullen2012-12-072-9/+0
| |
| * Added tag rabbitmq_v3_0_1 for changeset 43f92e93c7d0Simon MacMullen2012-12-060-0/+0
| |
| * Package changelogs for 3.0.1.Simon MacMullen2012-12-062-0/+9
| |
* | Fix a couple of partition-related specs.Simon MacMullen2012-12-102-2/+3
| |
* | fix spec bugsMatthias Radestock2012-12-061-5/+5
| |
* | Merged stable into defaultEmile Joubert2012-12-0512-388/+607
|\ \ | |/ |/|
| * merge stable into defaultMatthias Radestock2012-12-052-3/+17
| |\
| * \ stable to defaultSimon MacMullen2012-12-0412-388/+607
| |\ \
| | * | remove pre-0-9-1 cruftMatthias Radestock2012-12-041-8/+4
| | | |
| | * | Merged bug25328Emile Joubert2012-12-046-68/+123
| | |\ \
| | | * | yet more testsbug25328Matthias Radestock2012-12-031-2/+21
| | | | |
| | | * | test moreMatthias Radestock2012-12-031-9/+13
| | | | |
| | | * | add test for vq:fetchwhileMatthias Radestock2012-12-031-11/+20
| | | | |
| | | * | WhitespaceEmile Joubert2012-12-031-1/+1
| | | | |
| | | * | merge default into bug25328Matthias Radestock2012-11-306-58/+81
| | | |\ \ | | |/ / /
| | | * | merge default into bug25328Matthias Radestock2012-11-306-58/+81
| | | |\ \
| | | | * | return to a simpler, better BQ:dropwhile, and introduce 'fetchwhile'Matthias Radestock2012-11-296-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 Radestock2012-11-301-2/+2
| | |/ / /
| | * | | remove unused state varMatthias Radestock2012-11-301-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 defaultMatthias Radestock2012-11-2814-274/+269
| | |\ \
| | | * \ re-merge bug25303 into defaultMatthias Radestock2012-11-2714-274/+269
| | | |\ \
| | | | * \ Merge bug25323Simon MacMullen2012-11-277-57/+40
| | | | |\ \
| | | | | * | mark all messages enqueued in the slave as 'delivered'bug25323Matthias Radestock2012-11-267-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
| | | | * | | cosmeticMatthias Radestock2012-11-271-5/+3
| | | | | | |