summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Expand)AuthorAgeFilesLines
* All done.Matthew Sackman2009-08-031-7/+0
* Implemented. Seems to work well. Changed the design and behaviour of the back...Matthew Sackman2009-07-291-6/+12
* cosmeticMatthias Radestock2009-07-241-8/+4
* Pushed the binary exponential timeout / hibernate system into gen_server2. Ad...Matthew Sackman2009-07-061-41/+6
* updating gen_server2 with latest from R13B01 in order to ensure this doesn't ...Matthew Sackman2009-07-061-3/+1
* Done. In order to keep the code simple, the detection of naptime is done in r...Matthew Sackman2009-07-021-6/+45
* refactoring: rename "round robin" to "active consumers"bug20943Matthias Radestock2009-06-101-27/+31
* proper round-robining even when blockingMatthias Radestock2009-06-101-124/+111
* respect channel blocking when adding consumersbug20955Matthias Radestock2009-06-101-4/+11
* fix off-by-one errorMatthias Radestock2009-06-101-1/+1
* cosmeticMatthias Radestock2009-06-101-7/+9
* Made can_send/2 into can_send/3.Matthew Sackman2009-06-091-2/+1
* clean up tx records in queues when a transaction's channel diesbug20782Matthias Radestock2009-06-051-15/+32
* cosmetic: correct indentationMatthias Radestock2009-01-181-2/+2
* Merged 20071 into defaultBen Hood2009-01-161-62/+105
|\
| * Merged default into 18557Ben Hood2009-01-151-1/+2
| |\
| | * the #amqqueue.pid is 'none', so return self() insteadbug20089Matthias Radestock2009-01-091-1/+2
| * | tidying up, refactoring and some cosmetic changesMatthias Radestock2008-12-261-46/+27
| * | destroy limiter when a channel becomes unlimitedMatthias Radestock2008-12-241-11/+14
| * | deal with limiting after consumer subscriptionMatthias Radestock2008-12-231-1/+14
| * | make limiter keep track of all queues with subscriptionsMatthias Radestock2008-12-231-1/+11
| * | saner state transition handlingMatthias Radestock2008-12-191-52/+39
| * | fix bug: make sure consumers blocked due to limit are dropped from StateMatthias Radestock2008-12-191-5/+5
| * | Put some monitors inBen Hood2008-12-181-3/+0
| * | Got rid of superfluous PD readBen Hood2008-12-181-2/+1
| * | merge default into bug18557Matthias Radestock2008-12-181-6/+72
| |\ \ | | |/
| * | Dead queue informs limiterBen Hood2008-12-071-1/+4
| * | Now the channel sends the ack directly to the limiter instead of via the queueBen Hood2008-11-241-1/+0
| * | Got rid o the per-queue in-use capacityBen Hood2008-11-211-1/+1
| * | First cut with some actual load balancing workingBen Hood2008-11-201-9/+30
| * | SavepointBen Hood2008-11-191-2/+3
| * | Moved limiter out of the queue state into the process dictBen Hood2008-11-191-11/+7
| * | First stab at basic.qosBen Hood2008-11-181-25/+57
* | | turn queue processes into custom gen_serversbug20071Matthias Radestock2009-01-081-5/+5
| |/ |/|
* | merged default into bug18381bug18381Tony Garnock-Jones2008-12-091-0/+60
|\ \
| * | cosmetic renameMatthias Radestock2008-11-121-22/+17
| * | simplify info and info_all API, and extend info item listMatthias Radestock2008-11-111-8/+17
| * | beginnings of queue info APIMatthias Radestock2008-11-061-0/+56
* | | Update copyrights.bug19974Tony Garnock-Jones2008-12-091-6/+12
| |/ |/|
* | don't use gen_server hibernate featurebug19788Matthias Radestock2008-11-141-1/+3
|/
* hibernate some processes to conserve memorybug19468_channelsMatthias Radestock2008-10-211-34/+44
* Initial commit, from repo-rebase-20080703121916_default (e96543d904a2)Tony Garnock-Jones2008-07-031-0/+686