Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | 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... | ||||
* | | 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 | ||||
* | | | | | | | tweak credit_flow logic | Matthias Radestock | 2012-02-06 | 1 | -1/+1 |
| |_|_|_|_|/ |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - make credit specs contain the InitialCredit and MoreCreditAfter. This is more intuitive and means the message sender only needs to look at the former and the receiver at the latter. - narrow the condition on which handle_bump_msg invokes unblock - it only needs to do that on *transition* from =< 0 to > 0. - refactor: extract process dict update - cosmetic: more logical order of exported functions | ||||
* | | | | | | Update copyright 2012bug24606 | Emile Joubert | 2012-02-02 | 8 | -9/+9 |
| | | | | | | |||||
* | | | | | | Merged bug24671 into default | Emile Joubert | 2012-01-31 | 1 | -10/+2 |
|\ \ \ \ \ \ | |||||
| * | | | | | | get rid of debug and message logging | Matthias Radestock | 2012-01-26 | 1 | -10/+0 |
| | |_|_|_|/ | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | since they have limited use This does make the rabbit_log server somewhat superfluous, but it does get a new lease of life in bug 22470 | ||||
| * | | | | | reduce time complexity of binding removal on queue deletion | Matthias Radestock | 2011-11-30 | 1 | -0/+2 |
| | |_|_|/ | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | from O(n^2) to O(n). The solution comes in two parts: 1) a new table, rabbit_topic_trie_node, to explicitly track edge and binding counts of nodes in the trie. This eliminates expensive mnesia:match_object operations to determine these counts when needed. 2) table-scope write locks to eliminate row-level locking, which is expensive when there are many such locks in a single transaction | ||||
* | | | | | Remove ?CREDIT_CPU_BOUND and have /1 versions of ack and send instead.bug24671 | Simon MacMullen | 2012-01-24 | 1 | -1/+0 |
| | | | | | |||||
* | | | | | More credit for the queue -> msg_store case. | Simon MacMullen | 2012-01-19 | 1 | -0/+2 |
|/ / / / | |||||
* | | | | Refrain from resetting message expiry in message requeue | Emile Joubert | 2011-10-20 | 1 | -4/+1 |
|/ / / | |||||
* | | | the plugins distributions may be either ezs or directories | Alexandru Scvortov | 2011-09-22 | 1 | -0/+1 |
| | | | | | | | | | | | | Turns out the token parser was broken: it didn't work with nested tuples. | ||||
* | | | don't use the plugins directory | Alexandru Scvortov | 2011-09-22 | 1 | -0/+6 |
| | | | |||||
* | | | backing_queue_spec and variable_queue specs up to date | Alexandru Scvortov | 2011-08-05 | 1 | -2/+3 |
| | | | |||||
* | | | merge default into bug24216 | Matthias Radestock | 2011-07-04 | 2 | -15/+5 |
|\ \ \ | |||||
| * | | | tx gone from everywhere | Matthias Radestock | 2011-06-24 | 1 | -2/+1 |
| | | | | |||||
| * | | | remove transactions from backing queue | Matthias Radestock | 2011-06-24 | 1 | -13/+4 |
| | | | | | | | | | | | | | | | | ...and mostly from amqqueue_process | ||||
* | | | | Scratch space for exchanges, and rabbit_exchange:update/2. | Simon MacMullen | 2011-06-27 | 1 | -1/+2 |
|/ / / | |||||
* | | | Sort out (everywhere except mirror modules) slave pids and mirror nodes and ↵ | Matthew Sackman | 2011-06-21 | 1 | -1/+1 |
| | | | | | | | | | | | | 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 | -1/+1 |
|\ \ \ | |||||
| * | | | Permit dropping nodes of mirrored queues. This turns out to be much much ↵ | Matthew Sackman | 2011-05-24 | 1 | -2/+2 |
| | | | | | | | | | | | | | | | | messier than I'd hoped as the principle problem becomes ensuring an add after a drop works. Normally, an add would only occur on a node that has not seen said queue before: if it had, in a previous lifetime, then the booting of rabbit would have ripped out any locally stored files regarding that queue. But now this step may be missed. Having tried many different approaches, the simplest became expanding bq so that the shutdown reason is exposed to the BQ. Thus both slave and master can then detect that they're being dropped, and, in the case of master, it can convert a bq:terminate to a bq:delete_and_terminate. Every other approach I could think of turned out worse. | ||||
| * | | | Merge with default | Rob Harrop | 2011-05-20 | 1 | -1/+1 |
| |\ \ \ | |||||
| | * \ \ | Merging default to bug23554 | Matthew Sackman | 2011-05-17 | 2 | -4/+9 |
| | |\ \ \ | |||||
| | * \ \ \ | Merging default into bug23554 | Matthew Sackman | 2011-04-10 | 2 | -13/+20 |
| | |\ \ \ \ | |||||
| | | * | | | | Well txns are still only half in. But I want to go home. | Matthew Sackman | 2011-04-07 | 1 | -1/+2 |
| | | | | | | | |||||
| | | * | | | | Add BQ:discard, correct BQ:is_duplicate, finally fix the last bits of ↵ | Matthew Sackman | 2011-04-07 | 1 | -1/+2 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | immediate delivery, though hopefully in a way which has not leaked through to the lower layers... | ||||
| | | * | | | | Validate_msg becomes is_duplicate, which makes much more sense | Matthew Sackman | 2011-04-07 | 1 | -2/+2 |
| | | | | | | | |||||
| | | * | | | | merge default into bug23554 | Matthew Sackman | 2011-03-14 | 1 | -3/+6 |
| | | |\ \ \ \ | |||||
| | | * \ \ \ \ | Merge default to bug23554, and then a bit | Matthew Sackman | 2011-03-09 | 2 | -12/+17 |
| | | |\ \ \ \ \ | |||||
| | | | * | | | | | oops | Matthew Sackman | 2011-03-08 | 1 | -2/+2 |
| | | | | | | | | | |||||
| | | | * | | | | | add BQ:validate_message | Matthew Sackman | 2011-03-08 | 1 | -0/+2 |
| | | | | | | | | | |||||
| | | | * | | | | | Merging default into bug23554 | Matthew Sackman | 2011-03-08 | 2 | -12/+15 |
| | | | |\ \ \ \ \ | | | |/ / / / / / |