summaryrefslogtreecommitdiff
path: root/src/rabbit_queue_consumers.erl
Commit message (Expand)AuthorAgeFilesLines
* When we add a new consumer we might be inactive; make sure we transition to a...bug26389Simon MacMullen2014-09-251-2/+4
* Update copyright for 2014bug25940Simon MacMullen2014-03-171-1/+1
* Merge bug25957Simon MacMullen2014-03-061-36/+60
|\
| * Strip out support for x-prefetch.Simon MacMullen2014-03-041-5/+1
| * Management information on per-consumer prefetchSimon MacMullen2014-03-041-7/+9
| * Change the semantics of the basic.qos global flag to switch between per-consu...Simon MacMullen2014-03-041-8/+9
| * update_counter--Matthias Radestock2014-02-041-4/+3
| * Don't reinvent orddict:update_counter/3.Simon MacMullen2014-02-041-14/+6
| * Manage AckTag -> Ctag mapping in rabbit_queue_consumers, leave the channel ou...Simon MacMullen2014-02-031-15/+33
| * Merge defaultSimon MacMullen2014-02-031-18/+34
| |\
| | * merge default into bug24297Matthias Radestock2014-01-221-9/+9
| | |\
| | * \ merge default into bug24297Matthias Radestock2014-01-221-15/+14
| | |\ \
| | * | | We can't have drain=true and mode=auto so let's unify to a single mode: manua...Simon MacMullen2014-01-151-13/+15
| | * | | Unify rabbit_limiter:credit/5 and rabbit_limiter:set_consumer_prefetch/4.Simon MacMullen2014-01-151-13/+11
| | * | | Move credit args parsing into rabbit_queue_consumers, to reduce some nasty ar...Simon MacMullen2014-01-151-6/+18
| | * | | Undo gratuitous rename.Simon MacMullen2014-01-151-6/+6
| | * | | Rearrange order of function args in ack/reject/requeue for consistency.Simon MacMullen2014-01-141-2/+2
| | * | | Undo accidental unificationSimon MacMullen2014-01-131-5/+8
| | * | | Unbreak basic.reject, basic.nack and basic.recover. Fix up specs.Simon MacMullen2014-01-131-2/+3
| | * | | Ignore prefetch in autoack mode.Simon MacMullen2014-01-131-1/+1
| | * | | Merge in default.Simon MacMullen2014-01-131-27/+38
| | |\ \ \
| | * | | | Upon unblocking, unblock, and run message queue.Simon MacMullen2014-01-091-6/+10
| | * | | | More consistent namingSimon MacMullen2014-01-091-2/+2
| | * | | | Add initial support for x-prefetch consumer arg (basically auto-credit). It's...Simon MacMullen2014-01-081-14/+18
* | | | | | Start the consumer utilisation average at active 100% of the time, since when...bug26056Simon MacMullen2014-03-061-1/+1
|/ / / / /
* | | | | Try to get the weighting factor right.Simon MacMullen2014-01-271-6/+4
| |_|_|/ |/| | |
* | | | brevityMatthias Radestock2014-01-221-12/+12
* | | | cosmeticMatthias Radestock2014-01-221-2/+2
| |_|/ |/| |
* | | refactor: basic_consume/10 -> /9Matthias Radestock2014-01-221-8/+16
| |/ |/|
* | make draining part of r_limiter:creditbug25954Matthias Radestock2014-01-101-20/+19
* | revert most of http://hg.rabbitmq.com/rabbitmq-server/rev/5fddc5198854bug25938Matthias Radestock2014-01-101-2/+2
* | fix credit handlingMatthias Radestock2014-01-091-12/+23
|/
* merge bug25937 into bug25948Matthias Radestock2014-01-081-13/+10
|\
| * Even clearer?Simon MacMullen2014-01-071-14/+14
| * Maybe this is clearer?Simon MacMullen2014-01-071-15/+15
| * Simplfy (although perhaps not as much as we had hoped) by only informing queu...Simon MacMullen2014-01-071-17/+14
* | simplify rabbit_queue_consumers:deliver even furtherMatthias Radestock2014-01-071-15/+15
* | make rabbit_queue_consumers:deliver deliver at most one messageMatthias Radestock2014-01-071-29/+28
|/
* Fix handling of credit arriving with drain=true and an empty queue - we need ...Simon MacMullen2014-01-071-4/+4
* move consumer_use calculations into rabbit_queue_consumersMatthias Radestock2014-01-061-10/+45
* refactor: prepare for more stateMatthias Radestock2014-01-061-36/+45
* refactor: better var nameMatthias Radestock2013-12-241-10/+10
* specsMatthias Radestock2013-12-241-4/+48
* refactor: re-order and re-nameMatthias Radestock2013-12-241-65/+64
* cosmeticMatthias Radestock2013-12-231-1/+1
* extract all channel and consumer related queue functionalityMatthias Radestock2013-12-231-0/+339
View Lorry Controller Status