summaryrefslogtreecommitdiff
path: root/src/rabbit_variable_queue.erl
Commit message (Expand)AuthorAgeFilesLines
* Consistency between dropwhile and internal_fetchbug24874Emile Joubert2012-04-181-4/+4
* prevent badmatch in vqEmile Joubert2012-04-181-2/+2
* 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
| |\ \
| * | | don't discard accumulated changesAlexandru Scvortov2012-01-241-5/+5
| * | | don't remove expired messages until the DLQ has confirmed themAlexandru Scvortov2011-11-141-5/+9
| * | | don't remove rejected message before it is confirmed by the DLQAlexandru Scvortov2011-11-141-26/+28
| * | | amqqueue_process re-publishes with confirmsAlexandru Scvortov2011-11-141-16/+19
| * | | unbreak variable queue assertionsAlexandru Scvortov2011-11-071-2/+2
| * | | more consistent namingAlexandru Scvortov2011-11-071-14/+12
| * | | merge default into bug20337Alexandru Scvortov2011-11-071-55/+44
| |\ \ \
| * \ \ \ Crude merge-from-default to help examine this thing. Currently some tests fai...Simon MacMullen2011-10-201-8/+33
| |\ \ \ \
| | * | | | Tweaked read_msg_callback to not increment RamMsgCount and cleaned it up at t...Rob Harrop2011-06-201-14/+22
| | * | | | Refactored read_msg_callbackRob Harrop2011-06-201-14/+12
| | * | | | Rename MsgState -> AckEntryRob Harrop2011-06-201-2/+2
| | * | | | Updated specs and fixed error in ack that didn't account for different ack st...Rob Harrop2011-06-131-2/+2
| | * | | | Support for DL'ing messages that are rejected with requeue=falseRob Harrop2011-06-081-8/+17
| | * | | | Publishing under new GUID now. DL'd messages have x-death-reason and x-death-...Rob Harrop2011-06-081-5/+15
| | * | | | Merge with default and rough outline of DL for ttl expiryRob Harrop2011-06-071-7/+10
| | |\ \ \ \
| | | * | | | In progress tweaks to VQ to support returning the dropped message in dropwhileRob Harrop2011-04-061-19/+27
* | | | | | | Merged default.Francesco Mazzoli2012-02-071-2/+3
|\ \ \ \ \ \ \ | |_|_|_|_|/ / |/| | | | | |
| * | | | | | Using gen_secure/0 only when really needed.Francesco Mazzoli2012-02-071-2/+2
| * | | | | | Change naming in rabbit_guid, explicit guid passing in string/0 and binary/0.Francesco Mazzoli2012-01-171-2/+3
| | |_|_|/ / | |/| | | |
* | | | | | Update copyright 2012bug24606Emile Joubert2012-02-021-1/+1
| |_|_|_|/ |/| | | |
* | | | | two flavours of 'write'Matthias Radestock2012-01-171-3/+9
|/ / / /
* | | | Merge bug24308 (msg_store perf unnecessarily bounded by disk)Simon MacMullen2011-10-261-405/+297
|\ \ \ \
| * | | | a spot of inlining/renamingMatthias Radestock2011-10-241-29/+21
| * | | | Refrain from resetting message expiry in message requeueEmile Joubert2011-10-201-25/+22
| |/ / /