summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue.erl
Commit message (Collapse)AuthorAgeFilesLines
* 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
| | | | | | | | | |
| | | | | | * | | | Correct all manner of crazy wrongness with ↵Matthew Sackman2010-12-211-10/+11
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | maybe_run_queue_via_backing_queue. The principle problem is that the state with which the function is to be run is dependent on the caller. Sometimes it's the 'top level' BQ state (eg invocations called by amqqueue_process). Sometimes it's the 'bottom level' state (eg invocations called by vq or qi or msg_store). We didn't used to have multiple layers, but now we do. Consequently, the invocation must indicate 'where' the fun is to be run. The clearest explanation is in master:invoke/3
| | | | | | * | | | Merging default into bug 23554Matthew Sackman2010-12-211-10/+13
| | | | | | |\ \ \ \
| | | | | | | * | | | extra_pids => mirror_pids; Also rip out changes to the registry and just ↵Matthew Sackman2010-12-161-3/+3
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | hard code that rabbit_mnesia takes care of gm - the problem being that we need access to the table dfns even when rabbit app is stopped, thus the registry would be down
| | | | | | | * | | | inlineMatthew Sackman2010-12-141-3/+2
| | | | | | | | | | |
| | | | | | | * | | | Merging default into bug23554Matthew Sackman2010-12-141-2/+2
| | | | | | | |\ \ \ \
| | | | | | | * \ \ \ \ Merging in from defaultMatthew Sackman2010-12-091-5/+0
| | | | | | | |\ \ \ \ \
| | | | | | | * | | | | | On other node death, don't delete queues which still have some extra pids.Matthew Sackman2010-12-081-2/+4
| | | | | | | | | | | | |
| | | | | | | * | | | | | Merge default into bug 23554 (epic debitrot)Matthew Sackman2010-12-061-10/+13
| | | | | | | |\ \ \ \ \ \
| | | | | | | * | | | | | | Exposing the publishing chpid right through to the BQ (and tidying up ↵Matthew Sackman2010-11-301-4/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | tests/types/specs)
| | | | | | | * | | | | | | Make the tests work again. Also mirror_pids => extra_pids on the basis that ↵Matthew Sackman2010-11-291-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | it could be reusable for other purposes
| | | | | | | * | | | | | | Lesser of many evils...Matthew Sackman2010-11-291-5/+6
| | | | | | | | | | | | | |
* | | | | | | | | | | | | | Merge bug24128Simon MacMullen2011-06-061-9/+9
|\ \ \ \ \ \ \ \ \ \ \ \ \ \
| * | | | | | | | | | | | | | cosmeticMatthias Radestock2011-06-021-9/+9
| |/ / / / / / / / / / / / /
* | | | | | | | | | | | | | Optimisation while listing consumersEmile Joubert2011-05-311-1/+2
| | | | | | | | | | | | | |
* | | | | | | | | | | | | | rabbitmqctl report listing consumers more consistentlyEmile Joubert2011-05-271-2/+10
|/ / / / / / / / / / / / /
* | | | | | | | | | | | | Assert equivalence of x-message-ttlbug24133Matthew Sackman2011-05-251-1/+1
| |_|_|_|_|_|_|_|_|_|_|/ |/| | | | | | | | | | |
* | | | | | | | | | | | Merge in defaultSimon MacMullen2011-05-041-19/+13
|\ \ \ \ \ \ \ \ \ \ \ \
| * \ \ \ \ \ \ \ \ \ \ \ Merge in bug24009Simon MacMullen2011-04-081-19/+13
| |\ \ \ \ \ \ \ \ \ \ \ \ | | |/ / / / / / / / / / / | |/| | | | | | | | | | |
| | * | | | | | | | | | | Merge bug 24009 into bug 23939.Simon MacMullen2011-04-011-5/+6
| | |\ \ \ \ \ \ \ \ \ \ \
| | * \ \ \ \ \ \ \ \ \ \ \ Merge bug 24009 into bug 23939.Simon MacMullen2011-04-011-19/+13
| | |\ \ \ \ \ \ \ \ \ \ \ \
| | | * | | | | | | | | | | | DialyserSimon MacMullen2011-03-291-2/+2
| | | | | | | | | | | | | | |
| | | * | | | | | | | | | | | Better abstraction.Simon MacMullen2011-03-281-11/+4
| | | | | | | | | | | | | | |
| | | * | | | | | | | | | | | Fix on_node_down.Simon MacMullen2011-03-281-12/+11
| | | | | | | | | | | | | | |
| | | * | | | | | | | | | | | Make the tail fun in execute_mnesia_tx_with_tail *only* get executed after ↵Simon MacMullen2011-03-281-10/+6
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | the tx, and roll other uses into the tx fun. This is rather simpler hopefully.
| | | * | | | | | | | | | | | Only return the queue the second time round and thus don't call ↵Simon MacMullen2011-03-231-1/+7
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | XT:add_binding(#amqqueue{}, ...).
| | | * | | | | | | | | | | | Not 100% beautiful, but this gets serial ids into the hands of add_binding ↵Simon MacMullen2011-03-171-2/+2
| | | | |_|_|_|_|_|_|_|_|_|/ | | | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | and remove_binding.
* | | | | | | | | | | | | | Merge defaultRob Harrop2011-04-151-9/+11
|\ \ \ \ \ \ \ \ \ \ \ \ \ \ | |/ / / / / / / / / / / / / |/| | | | | | | | | | | | |
View Lorry Controller Status