summaryrefslogtreecommitdiff
path: root/src
Commit message (Expand)AuthorAgeFilesLines
* add type for header_routesAlexandru Scvortov2012-02-241-0/+3
* refactor amqqueue argument checkingAlexandru Scvortov2012-02-241-30/+25
* rename a functionAlexandru Scvortov2012-02-231-4/+4
* Cosmetic / reduce distance from default.Simon MacMullen2012-02-211-5/+5
* 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-173-33/+41
* simplify MsgFun logic for VQ:dropwhile/3 and VQ:ack/3Alexandru Scvortov2012-02-175-46/+44
* 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
* cosmeticMatthias Radestock2012-02-141-2/+2
* always issue credits, even when we drop a messageMatthias Radestock2012-02-141-30/+18
* cosmeticMatthias Radestock2012-02-142-28/+24
* Merge headsEmile Joubert2012-02-141-9/+12
|\
| * Merge bug24714Simon MacMullen2012-02-141-12/+7
| |\
| * | monitor nodes just onceMatthias Radestock2012-02-091-9/+12
* | | Merge bug20337 into defaultEmile Joubert2012-02-141-12/+7
|\ \ \ | | |/ | |/|
| * | simplifying refactorMatthias Radestock2012-02-131-12/+7
| |/
* | factor out redundant codeAlexandru Scvortov2012-02-141-15/+13
* | refactoringAlexandru Scvortov2012-02-142-20/+25
* | don't hang if purging an empty queue with dlxAlexandru Scvortov2012-02-121-2/+6
* | use lists:keydelete and only log cycles onceAlexandru Scvortov2012-02-122-14/+14
* | merge default into bug20337Alexandru Scvortov2012-02-1210-91/+459
|\ \ | |/ |/|
| * cosmeticAlexandru Scvortov2012-02-061-24/+21
| * merge default into bug20337Alexandru Scvortov2012-02-06105-564/+934
| |\
| * | refactor (Matthias's suggestions)Alexandru Scvortov2012-02-031-6/+2
| * | drop messages in dl cyclesAlexandru Scvortov2012-02-031-2/+45
| * | use same variable naming convention as in channelAlexandru Scvortov2012-01-311-20/+21
| * | don't leak queue monitorsAlexandru Scvortov2012-01-311-3/+41
| * | check that dlx is defined is dl-rk is setAlexandru Scvortov2012-01-301-2/+5
| * | check dlx routing key argAlexandru Scvortov2012-01-241-1/+11
| * | overwrite malformed x-death headersAlexandru Scvortov2012-01-241-3/+4
| * | don't discard accumulated changesAlexandru Scvortov2012-01-241-5/+5
| * | use POSIX timestamps instead of human readable onesAlexandru Scvortov2012-01-241-2/+2
| * | merge default into bug20337Alexandru Scvortov2012-01-2436-437/+565
| |\ \
| * | | add setting dlx routing key in queue.declareAlexandru Scvortov2011-12-052-9/+28
| * | | record routing keys and exchanges when dead-letteringAlexandru Scvortov2011-12-052-7/+16
| * | | include the time the message was dead-letteredAlexandru Scvortov2011-12-051-1/+3
| * | | merge default into bug20337Alexandru Scvortov2011-11-289-78/+317
| |\ \ \
| | * | | fix tuple arity mismatchAlexandru Scvortov2011-11-281-2/+2
| | * | | don't hang if there are no DLQs bound to the DLXAlexandru Scvortov2011-11-281-13/+24
| | * | | death headers are now stored in an array of tablesAlexandru Scvortov2011-11-281-8/+17