summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Expand)AuthorAgeFilesLines
* do not confirm 'immediate' messages that failed to be deliveredbug24845Matthias Radestock2012-04-031-13/+11
* refactor queue's confirm handling on publishMatthias Radestock2012-04-021-30/+28
* Merge bug24750.Simon MacMullen2012-04-021-79/+40
|\
| * merge default into bug24750Matthias Radestock2012-03-221-79/+40
| |\
| | * convert the queue to use dtree for confirm trackingMatthias Radestock2012-03-221-80/+40
* | | Merge bug23610Simon MacMullen2012-03-261-10/+7
|\ \ \
| * | | Cosmeticbug23610Simon MacMullen2012-03-261-2/+1
| * | | Notifying queue deletion in rabbit_amqqueue:internal_delete/2.Francesco Mazzoli2012-03-041-10/+8
* | | | ensure appropriate expiry of immediately delivered messagesbug24827Matthias Radestock2012-03-231-16/+8
* | | | cosmeticMatthias Radestock2012-03-231-4/+3
* | | | refactor/optimise 'reject'Matthias Radestock2012-03-231-6/+6
* | | | cosmeticMatthias Radestock2012-03-231-6/+4
| |/ / |/| |
* | | consistencyMatthias Radestock2012-03-221-1/+1
* | | cosmetic: log queue name with rabbit_misc:rs/1, like everywhere elseMatthias Radestock2012-03-221-2/+2
* | | fix a possible leakMatthias Radestock2012-03-221-4/+3
| |/ |/|
* | This fixes the bug, but it does not scatter-gather, which would certainly be ...Simon MacMullen2012-03-141-11/+12
|/
* In fact, let's not call handle_ch_down in the case where we get a 'DOWN' whil...bug24768Simon MacMullen2012-03-011-5/+9
* And a commentSimon MacMullen2012-03-011-0/+2
* Actually be slightly more minimal about what we move.Simon MacMullen2012-03-011-10/+10
* Don't throw away 'DOWN' in delayed_stop.Simon MacMullen2012-03-011-15/+16
* Merge bug24558Simon MacMullen2012-02-291-3/+3
|\
| * Using SYNC_INTERVAL for the idle timeout as well.Francesco Mazzoli2012-02-221-4/+3
| * Merge defaultFrancesco Mazzoli2012-02-161-3/+4
| |\
| | * Introduced a small timeout when needs_timeout returns 'idle'.Francesco Mazzoli2012-02-161-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-2/+1
* | | Extract some header-munging functions into rabbit_basic (not sure that's the ...Simon MacMullen2012-02-271-31/+10
* | | CosmeticSimon MacMullen2012-02-271-2/+1
* | | get rid of DLX warningsAlexandru Scvortov2012-02-271-30/+5
* | | don't remove DLX when not foundAlexandru Scvortov2012-02-241-11/+27
* | | rename the weird VQ:ack/3 head to VQ:process_messages/3Alexandru Scvortov2012-02-241-5/+5
* | | dead-lettering to a deleted exchange outputs an error and disables dead-lette...Alexandru Scvortov2012-02-241-7/+22
* | | I don't think the mk_ prefix helps us here.Simon MacMullen2012-02-211-4/+4
* | | rename delayed_delete into delayed_stopAlexandru Scvortov2012-02-171-11/+11
* | | ignore all messages after queue deletion, except for confirmsAlexandru Scvortov2012-02-171-10/+14
* | | hang subsequent queue deletionsAlexandru Scvortov2012-02-171-2/+7
* | | delay stopping the queue until all confirms have been receivedAlexandru Scvortov2012-02-171-22/+35
* | | simplify MsgFun logic for VQ:dropwhile/3 and VQ:ack/3Alexandru Scvortov2012-02-171-11/+13
* | | warn when messages are lostAlexandru Scvortov2012-02-161-0/+2
* | | BQ:ack batches of messagesAlexandru Scvortov2012-02-161-9/+9
* | | don't dead-letter on purgeAlexandru Scvortov2012-02-161-15/+1
* | | don't dead letter on queue deletionAlexandru Scvortov2012-02-161-43/+8
* | | rename ChPid to SenderPid where appropriateAlexandru Scvortov2012-02-151-13/+15
* | | dead-letter when auto-deletingAlexandru Scvortov2012-02-151-12/+24
* | | oopsAlexandru Scvortov2012-02-141-1/+1
* | | don't hang on multiple queue.purgesAlexandru Scvortov2012-02-141-21/+24
* | | always issue credits, even when we drop a messageMatthias Radestock2012-02-141-30/+18
* | | cosmeticMatthias Radestock2012-02-141-23/+19
* | | Merge bug20337 into defaultEmile Joubert2012-02-141-12/+7
|\ \ \ | |/ /
| * | simplifying refactorMatthias Radestock2012-02-131-12/+7
| |/