Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | stable to default | Simon MacMullen | 2013-01-24 | 3 | -4/+4 |
|\ | |||||
| * | Update copyright 2013bug25343 | Emile Joubert | 2013-01-23 | 3 | -4/+4 |
| | | |||||
* | | Remove that. | Simon MacMullen | 2013-01-18 | 1 | -1/+0 |
| | | |||||
* | | move a bunch of reader state fields into 'connection' | Matthias Radestock | 2012-12-28 | 1 | -3/+0 |
| | | | | | | | | | | | | | | These fields are constant, seldom read, and associated with the connection. Also, move #connection definition from rabbit.hrl to rabbit_reader - nothing else is using this and it is really private to the reader. | ||||
* | | mark all messages enqueued in the slave as 'delivered'bug25323 | Matthias Radestock | 2012-11-26 | 1 | -2/+1 |
|/ | | | | | | | | | which is a much better than the set_delivered logic, which we can now get rid of. In doing so it also becomes clear that having the 'delivered' flag in the #message_properties is less than ideal. It is mutable and we never bothered updating vq s.t. it sets the flag correctly. So lets get rid of it and add a parameter to bq:publish instead | ||||
* | Merge bug25244 | Simon MacMullen | 2012-10-29 | 1 | -0/+1 |
|\ | |||||
| * | move invalid headers into a special 'invalid headers table' header | Tim Watson | 2012-10-25 | 1 | -0/+1 |
| | | |||||
* | | Merge bug 24991 | Simon MacMullen | 2012-10-26 | 1 | -0/+9 |
|\ \ | |/ |/| | |||||
| * | merge default into bug24991 | Matthias Radestock | 2012-07-13 | 1 | -0/+9 |
| |\ | |||||
| | * | refactor: move constant and give it a better name | Matthias Radestock | 2012-06-12 | 1 | -0/+9 |
| | | | |||||
* | | | Progress towards storing a GM pid -> queue pid mapping. This is dependent on ↵ | Simon MacMullen | 2012-10-03 | 1 | -1/+2 |
| | | | | | | | | | | | | not feeding the process_death message into remove_from_queue - bug 25195 suggests this might be TRTTD. | ||||
* | | | Merge defaultbug24908 | Simon MacMullen | 2012-10-02 | 1 | -2/+1 |
|\ \ \ | |||||
| * \ \ | Merge in default | Simon MacMullen | 2012-09-25 | 1 | -2/+1 |
| |\ \ \ | |||||
| | * \ \ | Merge bug25048 | Simon MacMullen | 2012-07-09 | 1 | -2/+1 |
| | |\ \ \ | |||||
| | | * | | | Rough sketch of dynamic queue HA-ness: | Simon MacMullen | 2012-07-05 | 1 | -1/+1 |
| | | |/ / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * Remove #amqqueue.mirror_nodes, we will always derive this from policy * Remove everything to do with x-ha-* arguments * Abstract a bit more stuff into rabbit_mirror_queue_misc * Add a new "at-least" mode This works! Sort of. Changing policies on the fly, changing HAness altogether, having "at-least" set up a new mirror when one disappears, and probably some other things do not work. | ||||
* | | | | | s/redelivered/delivered/g | Simon MacMullen | 2012-09-26 | 1 | -1/+1 |
| | | | | | |||||
* | | | | | Stick redelivered in #message_properties, which makes the diff rather smaller. | Simon MacMullen | 2012-09-26 | 1 | -1/+2 |
|/ / / / | |||||
* | | | | nuke 'immediate'bug23896 | Matthias Radestock | 2012-09-17 | 1 | -1/+1 |
|/ / / | |||||
* | | | Store sync'ed slaves in Mnesia. This is not quite right yet. | Simon MacMullen | 2012-07-06 | 1 | -1/+2 |
|/ / | |||||
* | | First sketch of a policy mechanism. | Simon MacMullen | 2012-05-17 | 1 | -2/+2 |
| | | |||||
* | | Share the exchange scratch space | Simon MacMullen | 2012-04-26 | 1 | -1/+1 |
|/ | |||||
* | Merge in default | Simon MacMullen | 2012-04-19 | 5 | -213/+0 |
|\ | |||||
| * | According to Simon the .hrl files are not worth it. | Francesco Mazzoli | 2012-04-12 | 5 | -95/+0 |
| | | |||||
| * | Added dummy .hrl files so that we don't break files including them. | Francesco Mazzoli | 2012-04-12 | 5 | -0/+95 |
| | | |||||
| * | Added callback info for rabbit_backing_queue. | Francesco Mazzoli | 2012-04-02 | 1 | -71/+0 |
| | | | | | | | | | | | | There is a problem: I can't parametrise the callbacks by the ack() and state() type - before this problem was "solved" by including the .hrl file that relied on those types being defined. | ||||
| * | Added callback info to rabbit_msg_store. | Francesco Mazzoli | 2012-04-02 | 1 | -45/+0 |
| | | |||||
| * | Merged default. | Francesco Mazzoli | 2012-04-02 | 3 | -97/+0 |
| |\ | |||||
| | * | Added -callbacks for rabbit_auth_mechanism. | Francesco Mazzoli | 2012-03-05 | 1 | -28/+0 |
| | | | |||||
| | * | Added -callbacks for rabbit_auth_backend. | Francesco Mazzoli | 2012-03-05 | 1 | -31/+0 |
| | | | |||||
| | * | Added -callbacks for rabbit_exchange_type. Deleted ↵ | Francesco Mazzoli | 2012-03-05 | 1 | -38/+0 |
| | | | | | | | | | | | | | | | | | | | | | rabbit_exchange_type_spec.hrl. rabbit_exchange_type_invalid doesn't typecheck (rightfully), we need to change the type signature to remove the warning, but that's ugly... | ||||
* | | | Merge in default | Simon MacMullen | 2012-04-02 | 1 | -0/+2 |
|\ \ \ | |/ / |/| | | |||||
| * | | Rename cluster config to runtime parameters. | Simon MacMullen | 2012-03-26 | 1 | -1/+1 |
| | | | |||||
| * | | Simple CRUD for config-y Erlang terms | Simon MacMullen | 2012-03-19 | 1 | -0/+2 |
| |/ | |||||
* | | correct spec for BQ:dropwhile | Matthias Radestock | 2012-03-27 | 1 | -3/+4 |
|/ | |||||
* | re-order arguments to BQ:fold to look more like an Erlang fold | Alexandru Scvortov | 2012-02-28 | 1 | -1/+1 |
| | |||||
* | Rename process_messages to fold. | Simon MacMullen | 2012-02-27 | 1 | -1/+1 |
| | |||||
* | rename the weird VQ:ack/3 head to VQ:process_messages/3 | Alexandru Scvortov | 2012-02-24 | 1 | -2/+2 |
| | |||||
* | simplify MsgFun logic for VQ:dropwhile/3 and VQ:ack/3 | Alexandru Scvortov | 2012-02-17 | 1 | -7/+3 |
| | | | | | | MsgFun now takes a message (rather than a message reading callback). Also, only warn of lost messages when DLQ exits abnormally. | ||||
* | merge default into bug20337 | Alexandru Scvortov | 2012-02-12 | 1 | -3/+11 |
|\ | | | | | | | All tests pass. This also fixes the rabbit_guid rename. | ||||
| * | merge default into bug20337 | Alexandru Scvortov | 2012-02-06 | 8 | -19/+10 |
| |\ | |||||
| * \ | merge default into bug20337 | Alexandru Scvortov | 2012-01-24 | 1 | -0/+2 |
| |\ \ | |||||
| * | | | don't remove rejected message before it is confirmed by the DLQ | Alexandru Scvortov | 2011-11-14 | 1 | -5/+5 |
| | | | | |||||
| * | | | amqqueue_process re-publishes with confirms | Alexandru Scvortov | 2011-11-14 | 1 | -5/+5 |
| | | | | |||||
| * | | | more consistent naming | Alexandru Scvortov | 2011-11-07 | 1 | -4/+3 |
| | | | | |||||
| * | | | merge default into bug20337 | Alexandru Scvortov | 2011-11-07 | 1 | -4/+1 |
| |\ \ \ | |||||
| * \ \ \ | Crude merge-from-default to help examine this thing. Currently some tests ↵ | Simon MacMullen | 2011-10-20 | 1 | -3/+12 |
| |\ \ \ \ | | | | | | | | | | | | | | | | | | | fail due to q_p blowing up with failed assertions, I don't know if it was like that before. | ||||
| | * | | | | Tweaked read_msg_callback to not increment RamMsgCount and cleaned it up at ↵ | Rob Harrop | 2011-06-20 | 1 | -3/+3 |
| | | | | | | | | | | | | | | | | | | | | | | | | the same time | ||||
| | * | | | | Fixed up spec for msg_lookup_callback to contstrain input and output types ↵ | Rob Harrop | 2011-06-20 | 1 | -1/+1 |
| | | | | | | | | | | | | | | | | | | | | | | | | to be the same | ||||
| | * | | | | Merge with default | Rob Harrop | 2011-06-20 | 1 | -1/+0 |
| | |\ \ \ \ | |||||
| | * | | | | | Updated specs and fixed error in ack that didn't account for different ack ↵ | Rob Harrop | 2011-06-13 | 1 | -3/+12 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | storage formats |