summaryrefslogtreecommitdiff
path: root/include
Commit message (Collapse)AuthorAgeFilesLines
* Merged default.Francesco Mazzoli2012-04-023-97/+0
|\
| * Added -callbacks for rabbit_auth_mechanism.Francesco Mazzoli2012-03-051-28/+0
| |
| * Added -callbacks for rabbit_auth_backend.Francesco Mazzoli2012-03-051-31/+0
| |
| * Added -callbacks for rabbit_exchange_type. Deleted ↵Francesco Mazzoli2012-03-051-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:dropwhileMatthias Radestock2012-03-271-3/+4
|/
* re-order arguments to BQ:fold to look more like an Erlang foldAlexandru Scvortov2012-02-281-1/+1
|
* Rename process_messages to fold.Simon MacMullen2012-02-271-1/+1
|
* rename the weird VQ:ack/3 head to VQ:process_messages/3Alexandru Scvortov2012-02-241-2/+2
|
* simplify MsgFun logic for VQ:dropwhile/3 and VQ:ack/3Alexandru Scvortov2012-02-171-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 bug20337Alexandru Scvortov2012-02-121-3/+11
|\ | | | | | | All tests pass. This also fixes the rabbit_guid rename.
| * merge default into bug20337Alexandru Scvortov2012-02-068-19/+10
| |\
| * \ merge default into bug20337Alexandru Scvortov2012-01-241-0/+2
| |\ \
| * | | don't remove rejected message before it is confirmed by the DLQAlexandru Scvortov2011-11-141-5/+5
| | | |
| * | | amqqueue_process re-publishes with confirmsAlexandru Scvortov2011-11-141-5/+5
| | | |
| * | | more consistent namingAlexandru Scvortov2011-11-071-4/+3
| | | |
| * | | merge default into bug20337Alexandru Scvortov2011-11-071-4/+1
| |\ \ \
| * \ \ \ Crude merge-from-default to help examine this thing. Currently some tests ↵Simon MacMullen2011-10-201-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 Harrop2011-06-201-3/+3
| | | | | | | | | | | | | | | | | | | | | | | | the same time
| | * | | | Fixed up spec for msg_lookup_callback to contstrain input and output types ↵Rob Harrop2011-06-201-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | to be the same
| | * | | | Merge with defaultRob Harrop2011-06-201-1/+0
| | |\ \ \ \
| | * | | | | Updated specs and fixed error in ack that didn't account for different ack ↵Rob Harrop2011-06-131-3/+12
| | | | | | | | | | | | | | | | | | | | | | | | | | | | storage formats
* | | | | | | tweak credit_flow logicMatthias Radestock2012-02-061-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 2012bug24606Emile Joubert2012-02-028-9/+9
| | | | | |
* | | | | | Merged bug24671 into defaultEmile Joubert2012-01-311-10/+2
|\ \ \ \ \ \
| * | | | | | get rid of debug and message loggingMatthias Radestock2012-01-261-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 deletionMatthias Radestock2011-11-301-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.bug24671Simon MacMullen2012-01-241-1/+0
| | | | |
* | | | | More credit for the queue -> msg_store case.Simon MacMullen2012-01-191-0/+2
|/ / / /
* | | | Refrain from resetting message expiry in message requeueEmile Joubert2011-10-201-4/+1
|/ / /
* | | the plugins distributions may be either ezs or directoriesAlexandru Scvortov2011-09-221-0/+1
| | | | | | | | | | | | Turns out the token parser was broken: it didn't work with nested tuples.
* | | don't use the plugins directoryAlexandru Scvortov2011-09-221-0/+6
| | |
* | | backing_queue_spec and variable_queue specs up to dateAlexandru Scvortov2011-08-051-2/+3
| | |
* | | merge default into bug24216Matthias Radestock2011-07-042-15/+5
|\ \ \
| * | | tx gone from everywhereMatthias Radestock2011-06-241-2/+1
| | | |
| * | | remove transactions from backing queueMatthias Radestock2011-06-241-13/+4
| | | | | | | | | | | | | | | | ...and mostly from amqqueue_process
* | | | Scratch space for exchanges, and rabbit_exchange:update/2.Simon MacMullen2011-06-271-1/+2
|/ / /
* | | Sort out (everywhere except mirror modules) slave pids and mirror nodes and ↵Matthew Sackman2011-06-211-1/+1
| | | | | | | | | | | | deal with non-local queue declaration, and introduce ha policy and ha policy params. (does not compile)
* | | Merging default into bug23554Matthew Sackman2011-06-211-1/+1
|\ \ \
| * | | Permit dropping nodes of mirrored queues. This turns out to be much much ↵Matthew Sackman2011-05-241-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 defaultRob Harrop2011-05-201-1/+1
| |\ \ \
| | * \ \ Merging default to bug23554Matthew Sackman2011-05-172-4/+9
| | |\ \ \
| | * \ \ \ Merging default into bug23554Matthew Sackman2011-04-102-13/+20
| | |\ \ \ \
| | | * | | | Well txns are still only half in. But I want to go home.Matthew Sackman2011-04-071-1/+2
| | | | | | |
| | | * | | | Add BQ:discard, correct BQ:is_duplicate, finally fix the last bits of ↵Matthew Sackman2011-04-071-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 senseMatthew Sackman2011-04-071-2/+2
| | | | | | |
| | | * | | | merge default into bug23554Matthew Sackman2011-03-141-3/+6
| | | |\ \ \ \
| | | * \ \ \ \ Merge default to bug23554, and then a bitMatthew Sackman2011-03-092-12/+17
| | | |\ \ \ \ \
| | | | * | | | | oopsMatthew Sackman2011-03-081-2/+2
| | | | | | | | |
| | | | * | | | | add BQ:validate_messageMatthew Sackman2011-03-081-0/+2
| | | | | | | | |
| | | | * | | | | Merging default into bug23554Matthew Sackman2011-03-082-12/+15
| | | | |\ \ \ \ \ | | | |/ / / / / /