summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Expand)AuthorAgeFilesLines
* Revert changes to add proc_name via gen_server2, instead do it explicitly wit...bug25910Simon MacMullen2014-01-101-2/+2
* Merge in defaultSimon MacMullen2014-01-101-1/+2
|\
| * Merge in defaultSimon MacMullen2014-01-071-415/+147
| |\
| * | Add queue_coordinator / queue_syncer / gm. Shift to getting gen_server2 to st...Simon MacMullen2013-12-101-2/+2
| * | RenameSimon MacMullen2013-12-101-1/+1
| * | A bit more abstraction, plus identities for heartbeater /Simon MacMullen2013-12-101-1/+1
| * | Store some process identity in the process dictionary.Simon MacMullen2013-12-051-0/+1
* | | Merge bug25938 (again)Simon MacMullen2014-01-091-112/+1
|\ \ \
| * \ \ Merge bug25951Simon MacMullen2014-01-091-4/+3
| |\ \ \
| * | | | extract dead-letter publishing from rabbit_amqqueue_processbug25951Matthias Radestock2014-01-081-112/+1
* | | | | fix credit handlingMatthias Radestock2014-01-091-4/+9
| |/ / / |/| | |
* | | | cosmeticMatthias Radestock2014-01-091-4/+3
|/ / /
* | | merge default into bug25948bug25948Matthias Radestock2014-01-081-1/+1
|\ \ \
| * | | Rename this againbug25937Simon MacMullen2014-01-081-1/+1
* | | | simpler and more efficientMatthias Radestock2014-01-081-3/+1
* | | | merge bug25937 into bug25948Matthias Radestock2014-01-081-42/+38
|\ \ \ \ | |/ / /
| * | | Even clearer?Simon MacMullen2014-01-071-4/+4
| * | | Maybe this is clearer?Simon MacMullen2014-01-071-2/+2
| * | | Simplify further, don't use a proplistSimon MacMullen2014-01-071-2/+1
| * | | Simplfy (although perhaps not as much as we had hoped) by only informing queu...Simon MacMullen2014-01-071-26/+22
| | |/ | |/|
* | | simplifyMatthias Radestock2014-01-071-13/+12
* | | simplify rabbit_queue_consumers:deliver even furtherMatthias Radestock2014-01-071-18/+14
* | | better helperMatthias Radestock2014-01-071-26/+22
* | | keep State out of one of the FetchFunsMatthias Radestock2014-01-071-10/+14
* | | make rabbit_queue_consumers:deliver deliver at most one messageMatthias Radestock2014-01-071-46/+60
|/ /
* | Merge in defaultSimon MacMullen2014-01-071-0/+2
|\ \
| * \ Stable to defaultSimon MacMullen2014-01-071-7/+48
| |\ \
| * | | Notify on channel down.Simon MacMullen2014-01-071-0/+10
* | | | move consumer_use calculations into rabbit_queue_consumersMatthias Radestock2014-01-061-39/+6
* | | | refactor: better var nameMatthias Radestock2013-12-241-3/+3
* | | | merge default into bug25938Matthias Radestock2013-12-241-308/+71
|\ \ \ \ | |_|/ / |/| | |
| * | | reduce distance to defaultMatthias Radestock2013-12-241-1/+1
| * | | cosmeticMatthias Radestock2013-12-241-1/+1
| * | | oopsMatthias Radestock2013-12-231-1/+1
| * | | extract all channel and consumer related queue functionalityMatthias Radestock2013-12-231-383/+148
| | |/ | |/|
* | | merge stable into defaultMatthias Radestock2013-12-241-8/+6
|\ \ \ | | |/ | |/|
| * | refactor: inlineMatthias Radestock2013-12-241-8/+6
* | | refactor: introduce helper to simplify update_consumer_use call sitesMatthias Radestock2013-12-241-15/+15
* | | merge stable into defaultMatthias Radestock2013-12-231-12/+53
|\ \ \ | |/ / |/| / | |/
| * Announce credit flow state for channels and queues.Simon MacMullen2013-12-021-3/+3
| * Don't return consumer utilisation when idle or there are no consumers; no num...bug25882Simon MacMullen2013-11-201-6/+16
| * Simplify and remove magic numbers from the i/2 bit by treating time since las...Simon MacMullen2013-11-191-35/+23
| * Cosmetic / unused variables.Simon MacMullen2013-11-151-4/+4
| * Simplify: less state, less records, more pattern matching.Simon MacMullen2013-11-151-47/+33
| * Store timestamps as integers.Simon MacMullen2013-11-151-11/+11
| * Missed one + cosmetic.Simon MacMullen2013-11-151-10/+10
| * CU for "Consumer Utilisation" not CB for "Consumer Bound".Simon MacMullen2013-11-151-15/+15
| * Maintain an exponential moving average of the utilisation.Simon MacMullen2013-11-151-30/+43
| * Experiment with the idea of "consumer utilisation". Still far too lumpy.Simon MacMullen2013-11-141-18/+57
| * consumer_bound info item.Simon MacMullen2013-11-141-9/+14