Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | merge default into bug 23056bug23056 | Alexandru Scvortov | 2011-08-25 | 1 | -4/+5 |
|\ | |||||
| * | fix dialyzer warnings | Alexandru Scvortov | 2011-08-08 | 1 | -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 date | Alexandru Scvortov | 2011-08-05 | 1 | -3/+4 |
| | | |||||
* | | Shortstrs are actually up to 255. Derp.bug24357 | Matthew Sackman | 2011-08-22 | 1 | -1/+1 |
| | | |||||
* | | AMQP error reasons are shortstrs. Take advantage of ~p and limit to the ↵ | Matthew Sackman | 2011-08-22 | 1 | -1/+1 |
| | | | | | | | | shortstr length. | ||||
* | | Cosmeticsbug24285 | Matthew Sackman | 2011-08-17 | 1 | -3/+1 |
| | | |||||
* | | Merging default to bug24285 | Matthew Sackman | 2011-08-17 | 1 | -7/+8 |
|\ \ | |||||
| * | | replace undefined | token() with token() | Alexandru Scvortov | 2011-08-11 | 1 | -1/+1 |
| | | | |||||
| * | | merge from default | Alexandru Scvortov | 2011-08-11 | 1 | -23/+2 |
| |\ \ | | |/ | |||||
| * | | fix dialyzer types | Alexandru Scvortov | 2011-08-11 | 1 | -1/+1 |
| | | | |||||
| * | | unbreak amqqueue_process/limiter logic | Alexandru Scvortov | 2011-07-26 | 1 | -2/+2 |
| | | | |||||
| * | | finish refactoring | Alexandru Scvortov | 2011-07-26 | 1 | -2/+2 |
| | | | |||||
| * | | refactor | Alexandru Scvortov | 2011-07-26 | 1 | -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 channel | Alexandru Scvortov | 2011-07-25 | 1 | -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 MacMullen | 2011-08-09 | 1 | -1/+2 |
| | | | |||||
* | | | Various smaller QA things. | Simon MacMullen | 2011-08-08 | 1 | -3/+5 |
| | | | |||||
* | | | Merge in default | Simon MacMullen | 2011-08-05 | 1 | -0/+7 |
|\ \ \ | |_|/ |/| | | |||||
| * | | Introduce rabbit:force_event_refresh which will: | Simon MacMullen | 2011-08-01 | 1 | -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 default | Rob Harrop | 2011-08-04 | 1 | -1/+1 |
|\ \ | |||||
| * | | It has been decided that masking out on write, is preferable to masking out ↵bug24305 | Matthew Sackman | 2011-07-27 | 1 | -3/+2 |
| | | | | | | | | | | | | on read. | ||||
| * | | Wipe out slave pids whenever we start up a queue. | Matthew Sackman | 2011-07-26 | 1 | -1/+2 |
| |/ | |||||
* | | convert amqqueue_process's sync timer | Alexandru Scvortov | 2011-08-02 | 1 | -6/+1 |
| | | |||||
* | | refactor | Alexandru Scvortov | 2011-08-02 | 1 | -13/+2 |
| | | |||||
* | | merge default into bug23504 | Alexandru Scvortov | 2011-08-02 | 1 | -122/+152 |
|\ \ | |/ | |||||
| * | s/run_backing_queue_async/run_backing_queue | Matthias Radestock | 2011-06-25 | 1 | -3/+3 |
| | | | | | | | | as well as removing some mroe tx remnants from mirror_queue_slave | ||||
| * | get rid of sync run_backing_queue | Matthias Radestock | 2011-06-25 | 1 | -8/+1 |
| | | | | | | | | | | it was only needed for tx Also remove some tx remnants from mirror_queue_slave. | ||||
| * | tx gone from everywhere | Matthias Radestock | 2011-06-24 | 1 | -18/+5 |
| | | |||||
| * | Explode if the nodes policy has an empty list as the policy paramsbug23554 | Matthew Sackman | 2011-06-22 | 1 | -3/+4 |
| | | |||||
| * | Make an error more likely to be formatted sensibly | Matthew Sackman | 2011-06-22 | 1 | -1/+1 |
| | | |||||
| * | Be more helpful...and make it compile | Matthew Sackman | 2011-06-22 | 1 | -2/+2 |
| | | |||||
| * | Be more helpful | Matthew Sackman | 2011-06-22 | 1 | -12/+25 |
| | | |||||
| * | Sort out misc. (dnc) | Matthew Sackman | 2011-06-21 | 1 | -2/+2 |
| | | |||||
| * | Sort out (everywhere except mirror modules) slave pids and mirror nodes and ↵ | Matthew Sackman | 2011-06-21 | 1 | -29/+47 |
| | | | | | | | | deal with non-local queue declaration, and introduce ha policy and ha policy params. (does not compile) | ||||
| * | Merging default into bug23554 | Matthew Sackman | 2011-06-21 | 1 | -8/+32 |
| |\ | |||||
| | * | Merging default into bug23554 | Matthew Sackman | 2011-05-27 | 1 | -15/+39 |
| | |\ | |||||
| | | * | enforce equivalence checking of x-mirror arg | Matthew Sackman | 2011-05-25 | 1 | -1/+1 |
| | | | | |||||
| | | * | Not quite sure how I managed to get that quite so wrong... | Matthew Sackman | 2011-05-25 | 1 | -2/+1 |
| | | | | |||||
| | | * | Enforce checking of x-mirror arg | Matthew Sackman | 2011-05-25 | 1 | -1/+14 |
| | | | | |||||
| | | * | master must broadcast, esp if it doesn't know about the sender. Also rip out ↵ | Matthew Sackman | 2011-05-23 | 1 | -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 Sackman | 2011-05-20 | 1 | -2/+17 |
| | | | | |||||
| | | * | Add a sleep, to avoid tight spinning | Matthew Sackman | 2011-05-17 | 1 | -0/+1 |
| | | | | |||||
| | | * | Not especially happy with this but can't think of how else to solve this. If ↵ | Matthew Sackman | 2011-05-17 | 1 | -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 bug23554 | Matthew Sackman | 2011-05-17 | 1 | -20/+14 |
| | | |\ | |||||
| | | * \ | Merging default into bug23554 | Matthew Sackman | 2011-04-10 | 1 | -19/+26 |
| | | |\ \ | |||||
| | | | * \ | merge default into bug23554 | Matthew Sackman | 2011-03-14 | 1 | -16/+18 |
| | | | |\ \ | |||||
| | | | * \ \ | Merging default into bug23554 | Matthew Sackman | 2011-03-08 | 1 | -20/+26 |
| | | | |\ \ \ | |||||
| | | | | * \ \ | Merging bug23727 to bug23554 | Matthew Sackman | 2011-02-23 | 1 | -32/+20 |
| | | | | |\ \ \ | |||||
| | | | | * \ \ \ | Merging default into bug23554 | Matthew Sackman | 2011-02-12 | 1 | -20/+26 |
| | | | | |\ \ \ \ | |||||
| | | | | | * \ \ \ | Merging default into bug23554 (epic debitrot) | Matthew Sackman | 2011-01-20 | 1 | -20/+26 |
| | | | | | |\ \ \ \ | |||||
| | | | | | | * | | | | Use amqqueue:store_queue/1 so that we modify durable queues durably | Matthew Sackman | 2010-12-21 | 1 | -0/+1 |
| | | | | | | | | | | |