summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* eliminate unused var warningbug25962Matthias Radestock2014-01-151-1/+1
|
* drop support for channel.flow{active=false}Matthias Radestock2014-01-155-126/+25
|
* Merge bug 25954Simon MacMullen2014-01-1319-82/+137
|\
| * tiny simplifying refactorMatthias Radestock2014-01-101-2/+2
| |
| * Merge bug25910Simon MacMullen2014-01-100-0/+0
| |\
| * | Revert changes to add proc_name via gen_server2, instead do it explicitly ↵bug25910Simon MacMullen2014-01-1012-44/+33
| | | | | | | | | | | | with a helper macro.
| * | Merge in defaultSimon MacMullen2014-01-1019-92/+158
| |\ \ | | |/ | |/|
| | * This code can now be invoked in the context of the Erlang client, in which ↵Simon MacMullen2014-01-101-4/+3
| | | | | | | | | | | | case we are not guaranteed that the env key will be there at all.
| | * Automatically update process_name on become.Simon MacMullen2014-01-102-5/+13
| | |
| | * CosmeticSimon MacMullen2014-01-102-9/+6
| | |
| | * API tweak for the AMQP clientSimon MacMullen2014-01-081-9/+11
| | |
| | * Merge in defaultSimon MacMullen2014-01-0713-637/+840
| | |\
| | * | DocumentSimon MacMullen2013-12-181-0/+4
| | | |
| | * | Add queue_coordinator / queue_syncer / gm. Shift to getting gen_server2 to ↵Simon MacMullen2013-12-1013-31/+39
| | | | | | | | | | | | | | | | store the name in most cases.
| | * | Merge in defaultSimon MacMullen2013-12-106-78/+118
| | |\ \
| | * | | RenameSimon MacMullen2013-12-1011-26/+26
| | | | |
| | * | | A bit more abstraction, plus identities for heartbeater /Simon MacMullen2013-12-1013-65/+100
| | | | | | | | | | | | | | | | | | | | queue_collector / limiter.
| | * | | OopsSimon MacMullen2013-12-062-3/+3
| | | | |
| | * | | Store connection name in server writers (but not Erlang client ones)Simon MacMullen2013-12-062-18/+22
| | | | |
| | * | | Store some process identity in the process dictionary.Simon MacMullen2013-12-055-3/+12
| | | | |
* | | | | make draining part of r_limiter:creditbug25954Matthias Radestock2014-01-102-29/+34
|/ / / / | | | | | | | | | | | | | | | | | | | | which makes the contract more obvious and is also more efficient since we no longer trawl through all consumers in order to find drainable ones.
* | | | Merge headsSimon MacMullen2014-01-102-8/+6
|\ \ \ \
| * \ \ \ merge bug25938 into defaultMatthias Radestock2014-01-103-119/+146
| |\ \ \ \
| * | | | | revert most of http://hg.rabbitmq.com/rabbitmq-server/rev/5fddc5198854bug25938Matthias Radestock2014-01-102-8/+6
| | | | | | | | | | | | | | | | | | | | | | | | since it was wrong. except for the var renaming in r_queue_consumer:add.
* | | | | | Merge bug25817Simon MacMullen2014-01-1012-691/+901
|\ \ \ \ \ \ | | |/ / / / | |/| | | |
| * | | | | merge stable into defaultMatthias Radestock2014-01-101-4/+4
| |\ \ \ \ \
| | * | | | | simplify even furtherMatthias Radestock2014-01-101-4/+4
| | | | | | |
| * | | | | | merge stable into defaultMatthias Radestock2014-01-1021-769/+1124
| |\ \ \ \ \ \ | | |/ / / / / | |/| | | | |
| | * | | | | Merge bug25938 (again)Simon MacMullen2014-01-092-112/+142
| | |\ \ \ \ \ | | | |/ / / / | | |/| | | |
| | | * | | | Merge bug25951Simon MacMullen2014-01-093-64/+57
| | | |\ \ \ \
| | | * | | | | extract dead-letter publishing from rabbit_amqqueue_processbug25951Matthias Radestock2014-01-082-112/+142
| | | | | | | |
| | * | | | | | fix credit handlingMatthias Radestock2014-01-092-16/+32
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This cannot go via possibly_unblock since that deals with *channels* becoming unblocked only, whereas here we care about possibly unblocking a consumer on an otherwise unblocked channel.
| | * | | | | | merge default into bug25938Matthias Radestock2014-01-097-186/+182
| | |\ \ \ \ \ \ | | | | |/ / / / | | | |/| | | |
| | | * | | | | cosmeticMatthias Radestock2014-01-091-4/+3
| | | | | | | |
| | | * | | | | merge stable into defaultMatthias Radestock2014-01-0920-655/+965
| | | |\ \ \ \ \
| | | | * \ \ \ \ merge stable into defaultMatthias Radestock2014-01-0820-655/+965
| | | | |\ \ \ \ \ | | | | | |/ / / /
| | | | | * | | | Merge bug25948Simon MacMullen2014-01-080-0/+0
| | | | | |\ \ \ \
| | | | | * \ \ \ \ merge default into bug25948bug25948Matthias Radestock2014-01-083-14/+14
| | | | | |\ \ \ \ \ | | | | | | |/ / / /
| | | | | | * | | | stable to default (noop)Simon MacMullen2014-01-080-0/+0
| | | | | | |\ \ \ \
| | | | | | * \ \ \ \ Merge bug25937Simon MacMullen2014-01-082-12/+21
| | | | | | |\ \ \ \ \
| | | | | | | * \ \ \ \ (re)merge bug25942 into defaultMatthias Radestock2014-01-071-1/+1
| | | | | | | |\ \ \ \ \
| | | | | | | | * | | | | grrr, forgot onebug25942Matthias Radestock2014-01-071-1/+1
| | | | | | | | | | | | |
| | | | | | | * | | | | | (re)merge bug25942 into defaultMatthias Radestock2014-01-071-10/+10
| | | | | | | |\ \ \ \ \ \ | | | | | | | | |/ / / / / | | | | | | | | | | | | / | | | | | | | | |_|_|_|/ | | | | | | | |/| | | |
| | | | | | | | * | | | it turns out that dialyzer dislikes improper listsMatthias Radestock2014-01-071-10/+10
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...and spits out "Cons will produce an improper list" errors *sigh*
| | | | | | * | | | | | Rename this againbug25937Simon MacMullen2014-01-082-3/+3
| | | | | | | | | | | |
| | | | | * | | | | | | simpler and more efficientMatthias Radestock2014-01-081-3/+1
| | | | | | | | | | | |
| | | | | * | | | | | | merge bug25937 into bug25948Matthias Radestock2014-01-083-64/+52
| | | | | |\ \ \ \ \ \ \ | | | | | | |/ / / / / / | | | | | | | | | | | | | | | | | | | | | | | | and largely rewrite it in the process
| | | | | | * | | | | | Even clearer?Simon MacMullen2014-01-072-18/+18
| | | | | | | | | | | |
| | | | | | * | | | | | Maybe this is clearer?Simon MacMullen2014-01-072-17/+17
| | | | | | | | | | | |
| | | | | | * | | | | | Simplify further, don't use a proplistSimon MacMullen2014-01-072-4/+5
| | | | | | | | | | | |
View Lorry Controller Status