summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Expand)AuthorAgeFilesLines
* replace the sort with a gb_treebug23637Alexandru Scvortov2011-01-191-16/+11
* Mandatory delivery only needs to know that it got to the queue. Not the resul...Matthew Sackman2011-01-121-4/+5
* Prioritise both sync and async versions the sameMatthew Sackman2011-01-121-12/+13
* small simplifying refactorbug23593Matthias Radestock2011-01-101-16/+15
* merge default into bug23593Matthias Radestock2011-01-101-18/+25
|\
| * Merging bug23665 into defaultMatthew Sackman2011-01-101-2/+4
| |\
| * | more consistent namingbug23665Alexandru Scvortov2011-01-101-9/+10
| * | remove duplication of erroneous logicAlexandru Scvortov2011-01-101-18/+22
| |/
* | Msg -> MsgSeqNo; inline two functionsAlexandru Scvortov2011-01-101-21/+19
* | misspellingAlexandru Scvortov2011-01-101-2/+2
* | faulty logicAlexandru Scvortov2010-12-291-2/+3
* | amqqueue confirms in batchesAlexandru Scvortov2010-12-291-8/+28
|/
* remove dead codeAlexandru Scvortov2010-12-211-11/+5
* move another confirm into VQAlexandru Scvortov2010-12-211-3/+3
* simplify variable_queue:ack's return formatAlexandru Scvortov2010-12-211-3/+3
* the msg_store is responsible for confirming rejected messagesAlexandru Scvortov2010-12-201-7/+5
* the msg_store is now responsible for confirming messagesAlexandru Scvortov2010-12-201-2/+2
* amqqueue_process shouldn't confirm when a message is basic.got (it's the BQ's...Alexandru Scvortov2010-12-201-1/+1
* remove confirming of undelivered immediate messages from amqqueue_processAlexandru Scvortov2010-12-201-4/+1
* fix bug in consumer_delete event emission on queue terminationMatthias Radestock2010-12-171-1/+1
* merge bug23232 into defaultMatthias Radestock2010-12-151-11/+39
|\
| * Fixbug23232Simon MacMullen2010-12-031-3/+3
| * Consistency with other events.Simon MacMullen2010-12-031-8/+8
| * CosmeticSimon MacMullen2010-12-031-2/+2
| * FixSimon MacMullen2010-12-031-1/+2
| * Oops.Simon MacMullen2010-12-031-1/+1
| * Add consumer created / deleted events.Simon MacMullen2010-12-031-11/+38
* | improve consistency of APIMatthew Sackman2010-12-131-9/+6
* | Get rid of -import() statments.Marek Majkowski2010-12-081-4/+0
|/
* Added cosmetic change suggested in the bug reportRob Harrop2010-12-021-2/+1
* fix to compile and run under R12B5Alexandru Scvortov2010-12-021-3/+3
* cosmetic changesRob Harrop2010-11-251-4/+6
* merge from defaultAlexandru Scvortov2010-11-241-2/+8
|\
| * Matthew points out that erlang:now() can be rewritten as now().bug23460Simon MacMullen2010-11-161-2/+1
| * Reoprt idle_since pseudo-info-item.Simon MacMullen2010-11-161-2/+9
* | change order of tuple elementsAlexandru Scvortov2010-11-241-1/+1
* | cosmeticAlexandru Scvortov2010-11-241-7/+7
* | cosmetic + handle missing caseAlexandru Scvortov2010-11-241-14/+17
* | merge from defaultAlexandru Scvortov2010-11-171-21/+42
|\ \ | |/
| * Merging bug 22614 into defaultMatthew Sackman2010-11-111-8/+9
| |\
| * | Some inlining, and ensure that we limiter:deregister on ch_down (yes, limiter...bug22614Matthew Sackman2010-11-111-17/+8
| * | Merge with Matthew's cleanups.Jerry Kuch2010-11-111-15/+17
| |\ \
| | * | Minor moving about and cosmeticsMatthew Sackman2010-11-101-15/+9
| | * | Make use of the returned value from maybe_store as an assertion, as suggestedMatthew Sackman2010-11-101-7/+8
| * | | basic_cancel now unregisters limiter whenever consumer count zeroes; ch recor...Jerry Kuch2010-11-111-11/+21
| |/ /
| * | Refactor update_ch_record into maybe_store_record and make its use universal.Jerry Kuch2010-11-101-21/+24
| * | Improve function naming and handle other potential leak spots in channel reco...Jerry Kuch2010-11-101-11/+8
| * | Clean up trailing whitespace.Jerry Kuch2010-11-091-2/+1
| * | basic_cancel and channel_down handlers use new helper methodsJerry Kuch2010-11-091-10/+5
| * | Move function to be among its relatives.Jerry Kuch2010-11-091-12/+14