summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue.erl
Commit message (Collapse)AuthorAgeFilesLines
* merge default into bug 23056bug23056Alexandru Scvortov2011-08-251-4/+5
|\
| * fix dialyzer warningsAlexandru Scvortov2011-08-081-1/+1
| | | | | | | | | | The ones left now are mostly our over-specifying functions in interfaces and a couple of "crated function has no return".
| * amqqueue specs up to dateAlexandru Scvortov2011-08-051-3/+4
| |
* | Shortstrs are actually up to 255. Derp.bug24357Matthew Sackman2011-08-221-1/+1
| |
* | AMQP error reasons are shortstrs. Take advantage of ~p and limit to the ↵Matthew Sackman2011-08-221-1/+1
| | | | | | | | shortstr length.
* | Cosmeticsbug24285Matthew Sackman2011-08-171-3/+1
| |
* | Merging default to bug24285Matthew Sackman2011-08-171-7/+8
|\ \
| * | replace undefined | token() with token()Alexandru Scvortov2011-08-111-1/+1
| | |
| * | merge from defaultAlexandru Scvortov2011-08-111-23/+2
| |\ \ | | |/
| * | fix dialyzer typesAlexandru Scvortov2011-08-111-1/+1
| | |
| * | unbreak amqqueue_process/limiter logicAlexandru Scvortov2011-07-261-2/+2
| | |
| * | finish refactoringAlexandru Scvortov2011-07-261-2/+2
| | |
| * | refactorAlexandru Scvortov2011-07-261-3/+2
| | | | | | | | | | | | | | | Most of the changes in channel are due to it being called LimiterPid. So, we're going to call it Limiter now.
| * | start limiter before channelAlexandru Scvortov2011-07-251-4/+6
| | | | | | | | | | | | Also use an opaque type, a token, to invoke limiter functions.
* | | Export amqqueue:list/0. Remove filter_exit_map use and timer:sleep/1.Simon MacMullen2011-08-091-1/+2
| | |
* | | Various smaller QA things.Simon MacMullen2011-08-081-3/+5
| | |
* | | Merge in defaultSimon MacMullen2011-08-051-0/+7
|\ \ \ | |_|/ |/| |
| * | Introduce rabbit:force_event_refresh which will:Simon MacMullen2011-08-011-0/+7
| |/ | | | | | | | | | | | | * Emit a foo_exists for every foo that can emit foo_created * As a side effect, wake everything up and thus send out foo_stats events too. Currently this doesn't work for direct connections (rather more fiddly), but it does for everything else.
* | Merge bug24305 into defaultRob Harrop2011-08-041-1/+1
|\ \
| * | It has been decided that masking out on write, is preferable to masking out ↵bug24305Matthew Sackman2011-07-271-3/+2
| | | | | | | | | | | | on read.
| * | Wipe out slave pids whenever we start up a queue.Matthew Sackman2011-07-261-1/+2
| |/
* | convert amqqueue_process's sync timerAlexandru Scvortov2011-08-021-6/+1
| |
* | refactorAlexandru Scvortov2011-08-021-13/+2
| |
* | merge default into bug23504Alexandru Scvortov2011-08-021-122/+152
|\ \ | |/
| * s/run_backing_queue_async/run_backing_queueMatthias Radestock2011-06-251-3/+3
| | | | | | | | as well as removing some mroe tx remnants from mirror_queue_slave
| * get rid of sync run_backing_queueMatthias Radestock2011-06-251-8/+1
| | | | | | | | | | it was only needed for tx Also remove some tx remnants from mirror_queue_slave.
| * tx gone from everywhereMatthias Radestock2011-06-241-18/+5
| |
| * Explode if the nodes policy has an empty list as the policy paramsbug23554Matthew Sackman2011-06-221-3/+4
| |
| * Make an error more likely to be formatted sensiblyMatthew Sackman2011-06-221-1/+1
| |
| * Be more helpful...and make it compileMatthew Sackman2011-06-221-2/+2
| |
| * Be more helpfulMatthew Sackman2011-06-221-12/+25
| |
| * Sort out misc. (dnc)Matthew Sackman2011-06-211-2/+2
| |
| * Sort out (everywhere except mirror modules) slave pids and mirror nodes and ↵Matthew Sackman2011-06-211-29/+47
| | | | | | | | deal with non-local queue declaration, and introduce ha policy and ha policy params. (does not compile)
| * Merging default into bug23554Matthew Sackman2011-06-211-8/+32
| |\
| | * Merging default into bug23554Matthew Sackman2011-05-271-15/+39
| | |\
| | | * enforce equivalence checking of x-mirror argMatthew Sackman2011-05-251-1/+1
| | | |
| | | * Not quite sure how I managed to get that quite so wrong...Matthew Sackman2011-05-251-2/+1
| | | |
| | | * Enforce checking of x-mirror argMatthew Sackman2011-05-251-1/+14
| | | |
| | | * master must broadcast, esp if it doesn't know about the sender. Also rip out ↵Matthew Sackman2011-05-231-17/+2
| | | | | | | | | | | | | | | | the varying priority run_backing_queue* stuff as it turns out it's not needed
| | | * That's an awful lot of work to solve a potential memory leak...Matthew Sackman2011-05-201-2/+17
| | | |
| | | * Add a sleep, to avoid tight spinningMatthew Sackman2011-05-171-0/+1
| | | |
| | | * Not especially happy with this but can't think of how else to solve this. If ↵Matthew Sackman2011-05-171-2/+7
| | | | | | | | | | | | | | | | the queue has mirrors then you may well find that during death you try to contact a dead queue process, because the mnesia table is yet to be updated. In such cases, loop.
| | | * Merging default to bug23554Matthew Sackman2011-05-171-20/+14
| | | |\
| | | * \ Merging default into bug23554Matthew Sackman2011-04-101-19/+26
| | | |\ \
| | | | * \ merge default into bug23554Matthew Sackman2011-03-141-16/+18
| | | | |\ \
| | | | * \ \ Merging default into bug23554Matthew Sackman2011-03-081-20/+26
| | | | |\ \ \
| | | | | * \ \ Merging bug23727 to bug23554Matthew Sackman2011-02-231-32/+20
| | | | | |\ \ \
| | | | | * \ \ \ Merging default into bug23554Matthew Sackman2011-02-121-20/+26
| | | | | |\ \ \ \
| | | | | | * \ \ \ Merging default into bug23554 (epic debitrot)Matthew Sackman2011-01-201-20/+26
| | | | | | |\ \ \ \
| | | | | | | * | | | Use amqqueue:store_queue/1 so that we modify durable queues durablyMatthew Sackman2010-12-211-0/+1
| | | | | | | | | | |
View Lorry Controller Status