summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Expand)AuthorAgeFilesLines
* Switch to Erlang 17-style types, /0 versions at least.Simon MacMullen2014-09-171-1/+1
* Reify queue crashed state.Simon MacMullen2014-09-151-2/+9
* Improve commentsSimon MacMullen2014-09-111-1/+0
* Restart exclusive queues correctly, update comment.Simon MacMullen2014-09-101-43/+43
* Further reduce distance to default (especially in slave), by getting the preq...Simon MacMullen2014-09-101-6/+6
* Reduce distance to default, especially WRT rabbit_amqqueue_process startup.Simon MacMullen2014-09-091-43/+76
* Minor simplification.Simon MacMullen2014-09-091-7/+2
* Rename slightly and improve comments.Simon MacMullen2014-09-091-3/+3
* Unmislead comment.Simon MacMullen2014-08-211-1/+1
* Allow crashing queues to recover themselves.Simon MacMullen2014-08-191-34/+45
* Roll slave startup into the new mechanism.Simon MacMullen2014-08-191-2/+1
* Various spec-ish fixes.Simon MacMullen2014-08-191-2/+0
* First step along the way to queue restarts. Create a "prequeue" module whose ...Simon MacMullen2014-08-191-83/+55
* Renamebug25884Simon MacMullen2014-08-121-1/+1
* And max-length is implemented in terms of messages_ready, so do the same for ...Simon MacMullen2014-08-121-1/+1
* Max-bytes argument / policy.Simon MacMullen2014-08-121-27/+37
* Merge in defaultSimon MacMullen2014-08-111-4/+2
|\
| * Dialyzer points out that the false branch cannot happen. In bug 26204 we remo...Simon MacMullen2014-08-081-4/+2
* | Merge in bug26307 and update.Simon MacMullen2014-07-291-7/+6
|\ \ | |/
| * Make some of the more interesting bits of the VQ backing_queue_status an offi...Simon MacMullen2014-07-291-7/+6
* | First pass at queue-size-in-bytes. Only lightly tested, and with no upgrade s...Simon MacMullen2014-07-231-2/+5
|/
* Maintain down_slave_nodes so we might have a clue where to look to recover from.Simon MacMullen2014-06-191-0/+9
* Init the stats timer again on force_event_refresh, so that if stats have beco...Simon MacMullen2014-06-101-1/+1
* Support long timers.Simon MacMullen2014-05-231-2/+2
* Remove rabbit_amqqueue:force_event_refresh/1 synchronybug26127Simon MacMullen2014-04-171-19/+19
* Update copyright for 2014bug25940Simon MacMullen2014-03-171-1/+1
* merge default into bug25589bug25589Matthias Radestock2014-03-171-19/+27
|\
| * Management information on per-consumer prefetchSimon MacMullen2014-03-041-16/+21
| * Change the semantics of the basic.qos global flag to switch between per-consu...Simon MacMullen2014-03-041-8/+9
| * Merge in defaulbug24297Simon MacMullen2014-03-041-7/+7
| |\
| | * OopsSimon MacMullen2014-03-041-7/+7
| * | Merge in defaultSimon MacMullen2014-03-041-2/+11
| |\ \ | | |/
| * | Merge in defaultSimon MacMullen2014-02-181-30/+38
| |\ \
| * | | Manage AckTag -> Ctag mapping in rabbit_queue_consumers, leave the channel ou...Simon MacMullen2014-02-031-16/+15
| * | | Merge defaultSimon MacMullen2014-02-031-17/+20
| |\ \ \
| | * \ \ merge default into bug24297Matthias Radestock2014-01-221-1/+1
| | |\ \ \
| | * \ \ \ merge default into bug24297Matthias Radestock2014-01-221-4/+0
| | |\ \ \ \
| | * | | | | Move credit args parsing into rabbit_queue_consumers, to reduce some nasty ar...Simon MacMullen2014-01-151-3/+2
| | * | | | | Rearrange order of function args in ack/reject/requeue for consistency.Simon MacMullen2014-01-141-9/+9
| | * | | | | Unbreak basic.reject, basic.nack and basic.recover. Fix up specs.Simon MacMullen2014-01-131-9/+9
| | * | | | | Merge in default.Simon MacMullen2014-01-131-120/+14
| | |\ \ \ \ \
| | * | | | | | Upon unblocking, unblock, and run message queue.Simon MacMullen2014-01-091-4/+7
| | * | | | | | More consistent namingSimon MacMullen2014-01-091-3/+3
| | * | | | | | Add initial support for x-prefetch consumer arg (basically auto-credit). It's...Simon MacMullen2014-01-081-9/+9
* | | | | | | | decouple syncing from pagingMatthias Radestock2014-03-031-2/+3
* | | | | | | | limit alpha->beta conversion through msg store credit flowMatthias Radestock2014-03-031-1/+1
| |_|_|_|_|_|/ |/| | | | | |
* | | | | | | Sort by descending priority order, and add a comment.bug25994Simon MacMullen2014-02-241-2/+11
* | | | | | | always prioritise acks (and resume)Matthias Radestock2014-02-241-2/+2
| |_|_|_|_|/ |/| | | | |
* | | | | | Merge in defaultSimon MacMullen2014-02-101-27/+34
|\ \ \ \ \ \
| * | | | | | don't sync so oftenbug26001Matthias Radestock2014-02-061-2/+2