summaryrefslogtreecommitdiff
path: root/src/rabbit_variable_queue.erl
Commit message (Expand)AuthorAgeFilesLines
* leave the ram_msg_count unchanged in BQ:foldbug25306Matthias Radestock2012-11-221-5/+7
* assert after foldMatthias Radestock2012-11-211-7/+6
* assertionMatthias Radestock2012-11-201-0/+1
* no more blind confirmsMatthias Radestock2012-10-161-5/+2
* publish_delivered(false, ...) -> discardMatthias Radestock2012-10-161-15/+6
* stylistic consistencyMatthias Radestock2012-10-011-1/+1
* s/redelivered/delivered/gSimon MacMullen2012-09-261-2/+2
* Stick redelivered in #message_properties, which makes the diff rather smaller.Simon MacMullen2012-09-261-12/+13
* Mark enqueued-on-promotion messages as redeliveredSimon MacMullen2012-09-261-13/+13
* track the delta of the depths, and replace `pending_ack' with `depth' in BQFrancesco Mazzoli2012-09-041-3/+3
* add a callback to backing queue to get the number of pending acksFrancesco Mazzoli2012-08-311-2/+5
* schedule message expiry timer based on expiry time of queue headMatthias Radestock2012-08-121-4/+4
* cosmetic(ish)Matthias Radestock2012-05-261-10/+8
* Fiddle with commentsbug24729Simon MacMullen2012-05-031-6/+7
* Removed unused types, added dummy -spec to silence compilerFrancesco Mazzoli2012-05-011-3/+7
* merge defaultFrancesco Mazzoli2012-05-011-1/+4
|\
| * Add comment explaining why ack() and state() exist.Francesco Mazzoli2012-04-241-1/+4
* | Make rabbit_variable_queue:dropwhile tail recursiveFrancesco Mazzoli2012-04-231-5/+6
* | Clearer var naming in BQ:dropwhile. Fix in amqqueue_process:drop_expired_mess...Francesco Mazzoli2012-04-231-6/+6
* | Changed BQ:dropwhile/3 to take a boolean arg to decide wether to ack or not.Francesco Mazzoli2012-04-191-16/+18
|/
* Defensive programmingMatthew Sackman2012-04-191-1/+1
* merge bug24874 into defaultMatthias Radestock2012-04-181-4/+4
|\
| * Consistency between dropwhile and internal_fetchbug24874Emile Joubert2012-04-181-4/+4
| * prevent badmatch in vqEmile Joubert2012-04-181-2/+2
* | Merge bug24729Simon MacMullen2012-04-171-3/+1
|\ \ | |/ |/|
| * Added callback info for rabbit_backing_queue.Francesco Mazzoli2012-04-021-3/+1
* | cosmeticMatthias Radestock2012-04-111-7/+5
* | Changed uses of gb_sets:difference/2 to our difference functions.Francesco Mazzoli2012-04-111-4/+7
|/
* Merge bug24558Simon MacMullen2012-02-291-22/+21
|\
| * Assert in timeout, better sync comment, changed naming of needs_index_sync.Francesco Mazzoli2012-02-291-4/+4
| * Checking for memory usage in needs_timeoutFrancesco Mazzoli2012-02-221-4/+12
| * Removed reduce_memory_use test before actual reduce_memory_use in timeout/1.Francesco Mazzoli2012-02-221-8/+1
| * Got rid of unused function and warnings.Francesco Mazzoli2012-02-091-10/+3
| * Merged defaultFrancesco Mazzoli2012-02-091-3/+4
| |\
| * | Syncing instead of flushing.Francesco Mazzoli2012-02-091-6/+2
| * | Returning idle in needs_timeout/1 only when there is something to flush.Francesco Mazzoli2012-02-071-3/+6
| * | Always returning either timed or idle, always flushing in timeout/1.Francesco Mazzoli2012-02-071-30/+12
| * | Flushing periodically, trying out various way to find out when to flush.Francesco Mazzoli2012-02-071-13/+37
* | | re-order arguments to BQ:fold to look more like an Erlang foldAlexandru Scvortov2012-02-281-2/+2
* | | Rename process_messages to fold.Simon MacMullen2012-02-271-3/+3
* | | CosmeticSimon MacMullen2012-02-271-1/+0
* | | add missing headAlexandru Scvortov2012-02-241-0/+2
* | | rename the weird VQ:ack/3 head to VQ:process_messages/3Alexandru Scvortov2012-02-241-14/+14
* | | Cosmetic / reduce distance from default.Simon MacMullen2012-02-211-5/+5
* | | simplify MsgFun logic for VQ:dropwhile/3 and VQ:ack/3Alexandru Scvortov2012-02-171-26/+14
* | | cosmeticMatthias Radestock2012-02-141-2/+2
* | | cosmeticMatthias Radestock2012-02-141-5/+5
* | | factor out redundant codeAlexandru Scvortov2012-02-141-15/+13
* | | merge default into bug20337Alexandru Scvortov2012-02-121-14/+46
|\ \ \ | |_|/ |/| |
| * | merge default into bug20337Alexandru Scvortov2012-02-061-4/+10
| |\ \
View Lorry Controller Status