summaryrefslogtreecommitdiff
path: root/src/rabbit_backing_queue.erl
Commit message (Collapse)AuthorAgeFilesLines
* Removed unused types, added dummy -spec to silence compilerFrancesco Mazzoli2012-05-011-2/+0
|
* Clearer var naming in BQ:dropwhile. Fix in ↵Francesco Mazzoli2012-04-231-2/+2
| | | | | | | | | amqqueue_process:drop_expired_messages. Also, corrected the dropwhile-related comments in rabbit_backing_queue. For what concerns the fix in drop_expired_messages, I was wrongly generating acktags for dead messages not to be dead-lettered.
* Update comment for bq:dropwhile specFrancesco Mazzoli2012-04-191-3/+4
|
* Changed BQ:dropwhile/3 to take a boolean arg to decide wether to ack or not.Francesco Mazzoli2012-04-191-3/+5
| | | | | | I'm most likely going to change this to two different functions, the only thing that is holding me back is that I'll end up writing one function and then two wrappers around it in both instances (variable_queue and queue_master).
* Added callback info for rabbit_backing_queue.Francesco Mazzoli2012-04-021-156/+192
| | | | | | There is a problem: I can't parametrise the callbacks by the ack() and state() type - before this problem was "solved" by including the .hrl file that relied on those types being defined.
* Rename process_messages to fold.Simon MacMullen2012-02-271-1/+1
|
* rename the weird VQ:ack/3 head to VQ:process_messages/3Alexandru Scvortov2012-02-241-3/+7
|
* merge default into bug20337Alexandru Scvortov2012-02-061-1/+1
|\
| * Update copyright 2012bug24606Emile Joubert2012-02-021-1/+1
| |
* | don't remove rejected message before it is confirmed by the DLQAlexandru Scvortov2011-11-141-7/+4
| |
* | amqqueue_process re-publishes with confirmsAlexandru Scvortov2011-11-141-4/+7
| |
* | merge default into bug20337Alexandru Scvortov2011-11-071-1/+1
|\ \ | |/
| * Refrain from resetting message expiry in message requeueEmile Joubert2011-10-201-1/+1
| |
* | Crude merge-from-default to help examine this thing. Currently some tests ↵Simon MacMullen2011-10-201-4/+8
|\ \ | |/ |/| | | fail due to q_p blowing up with failed assertions, I don't know if it was like that before.
| * Updated specs and fixed error in ack that didn't account for different ack ↵Rob Harrop2011-06-131-2/+6
| | | | | | | | storage formats
| * Support for DL'ing messages that are rejected with requeue=falseRob Harrop2011-06-081-1/+1
| |
| * Merge with default and rough outline of DL for ttl expiryRob Harrop2011-06-071-1/+1
| |\
* | | remove transactions from backing queueMatthias Radestock2011-06-241-19/+2
|/ / | | | | | | ...and mostly from amqqueue_process
* | Reduce diff from bug23554: Extend backing queue api to present reason for ↵Matthew Sackman2011-06-021-2/+2
| | | | | | | | termination
* | BQ:idle_timeout => BQ:timeoutbug24117Matthew Sackman2011-05-191-2/+2
| |
* | BQ:needs_idle_timeout :: State -> Bool ==> BQ:needs_timeout :: State -> ↵Matthew Sackman2011-05-181-4/+4
| | | | | | | | (false | idle | timed); which better reflects the different needs
* | Extensions to BQMatthew Sackman2011-04-081-10/+27
|/
* englishMatthew Sackman2011-03-291-5/+5
|
* Improve documentation of BQ concerning the issuance of confirmsMatthew Sackman2011-03-291-7/+31
|
* more docsMatthias Radestock2011-03-141-5/+7
|
* I didn't think that implied that it could *only* be used out of process, but ↵bug23882Simon MacMullen2011-03-141-2/+2
| | | | let's make it clearer.
* I think this makes it more comprehensible. To me at least.Simon MacMullen2011-03-141-2/+3
|
* merge default into bug23882Matthias Radestock2011-03-071-1/+1
|\
| * guid -> msg_idMatthias Radestock2011-03-041-1/+1
| |
* | document bq init paramsMatthias Radestock2011-03-071-0/+12
| |
* | make handling of confirms more obvious in BQ APIMatthias Radestock2011-03-051-0/+4
| | | | | | | | | | and fix some bugs introduced earlier ...amazingly it all seems to work now
* | beginnings of decoupling bq from amqqueueMatthias Radestock2011-03-041-1/+1
|/ | | | - parameterise bq with callbacks
* Update .erl and .hrl license boilerplatesMatthew Sackman2011-01-191-26/+11
|
* Simplify code surrounding the return from BQ:ackMatthew Sackman2010-12-141-1/+1
|
* TextualityMatthew Sackman2010-10-211-2/+2
|
* removed peek, and restructured dropwhile to not load message content from diskRob Harrop2010-09-281-3/+0
|
* added peek to backing queue, implemented in vqRob Harrop2010-09-271-0/+3
|
* reworked how message filtering works with dropwhileRob Harrop2010-09-221-0/+4
|
* added msg_properties to publish_delivered so they can be rehydrated laterRob Harrop2010-09-171-1/+1
|
* reworked backing_queue and variable_queue to store msg_properties. used msg ↵Rob Harrop2010-08-181-4/+4
| | | | properties for storing and manipulating message expiry
* flesh out backing_queue APIMatthias Radestock2010-07-211-0/+5
|
* 'sync' -> 'idle_timeout'Matthias Radestock2010-07-191-8/+9
| | | | cherry-picked from bug 21673.
* 2009 => 2010bug22824Matthew Sackman2010-06-021-3/+3
|
* pluggable queue backendsbug22616Matthias Radestock2010-05-031-0/+133
- behaviour and specs for pluggable queue backends - reworking of the queue code to support pluggability, including hookups to memory monitoring and file handle management - interface to existing persister via the new API All these changes were cherry-picked from the bug21673 branch.
View Lorry Controller Status