summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Collapse)AuthorAgeFilesLines
* Uh, that function needs another headerbug25945Simon MacMullen2014-01-071-1/+3
|
* Notify on channel down.Simon MacMullen2014-01-071-0/+10
|
* refactor: inlineMatthias Radestock2013-12-241-8/+6
|
* various simplifying refactorsMatthias Radestock2013-12-231-93/+93
| | | | | these are actually all quite trivial; the diffs are large mainly due to whitspace and renames
* tiny refactorsMatthias Radestock2013-12-231-6/+8
|
* cosmetic, largely whitespaceMatthias Radestock2013-12-231-10/+10
|
* Merged stable into defaultEmile Joubert2013-10-151-11/+11
|\
| * Always check message expiry when queues startbug25815Emile Joubert2013-10-141-13/+14
| |
* | Merged bug25749 into defaultEmile Joubert2013-09-131-8/+6
|\ \
| * \ Merge in defaultbug25276Simon MacMullen2013-09-111-12/+6
| |\ \
| | * \ merge stable into defaultMatthias Radestock2013-09-111-8/+2
| | |\ \ | | | |/
| | | * Remove the warning message, it's not very interesting. Also fix an unused ↵bug25757Simon MacMullen2013-09-111-7/+1
| | | | | | | | | | | | | | | | variable.
| | | * Introduce a new return code for this case, since {new, Q} is going to mess ↵Simon MacMullen2013-09-091-5/+1
| | | | | | | | | | | | | | | | up recovery by claiming we recovered something we didn't. Also {existing, Q} would make the channel enter an infinite loop, and {absent, Q} would return an AMQP NOT_FOUND which might be bewildering to the client if it managed to receive it. So we need a fourth possibility.
| | | * Reply with something the channel is going to know how to handle.Simon MacMullen2013-09-091-1/+5
| | | |
| * | | Explain a little.Simon MacMullen2013-09-091-1/+5
| |/ /
| * | merge stable into defaultMatthias Radestock2013-09-091-1/+1
| |\ \ | | |/
| | * correctly prettify exclusive owner dissappearance warningMatthias Radestock2013-09-091-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | WRONG: Queue "queue 'amq.gen-FQZtyp6mpRdmm3-on_LAOQ' in vhost 'urhyfncz'" exclusive owner went away RIGHT: exclusive owner for queue 'amq.gen-FQZtyp6mpRdmm3-on_LAOQ' in vhost 'urhyfncz' went away This got broken in http://hg.rabbitmq.com/rabbitmq-server/rev/f9f4919656ab
* | | Version TTL and expiry messages, and ignore the wrong ones. Also stop timers ↵Simon MacMullen2013-09-111-13/+29
| | | | | | | | | | | | and then start them again when re-initing.
* | | Hook TTL / max length / expiry into policy system.Simon MacMullen2013-09-061-28/+33
| | |
* | | Merge in defaultSimon MacMullen2013-09-051-8/+47
|\ \ \ | |/ /
| * | Merge in bug25725.Simon MacMullen2013-08-221-8/+47
| |\ \
| | * \ Merge defaultSimon MacMullen2013-08-211-48/+99
| | |\ \
| | | * | Rename notification_requested to refresh, and emit queue_empty rather than ↵Simon MacMullen2013-08-211-3/+3
| | | | | | | | | | | | | | | | | | | | queue_run_finished - we don't care if the queue run has finished and we are not empty, but we *do* care if we have become empty by some other method (purge, TTL).
| | | * | Notify "startup" when we fail over too, that means the federation links will ↵Simon MacMullen2013-08-211-3/+5
| | | | | | | | | | | | | | | | | | | | fail over with us.
| | | * | Slightly clearer?Simon MacMullen2013-08-211-10/+10
| | | | |
| | | * | Small changes: Don't reevaluate consumer priority on every delivery, ↵Simon MacMullen2013-08-211-15/+14
| | | | | | | | | | | | | | | | | | | | refactor a touch, realign, fix test, more specific spec.
| | | * | Push everything through notify_decorators/3.Simon MacMullen2013-08-201-11/+15
| | | | |
| | | * | Merge defaultSimon MacMullen2013-08-161-32/+78
| | | |\ \ | | | | |/ | | | |/|
| | | | * More symmetry; notify on basic consume and consumer unblock as well as ↵Simon MacMullen2013-07-241-2/+9
| | | | | | | | | | | | | | | | | | | | basic.cancel and consumer block.
| | | | * Slightly clearer names?Simon MacMullen2013-07-241-2/+2
| | | | |
| | | | * Don't emit random bits of the queue's internal data structures in events.Simon MacMullen2013-07-241-4/+6
| | | | |
| | | | * Extend queue decorator interface, break dependency of server on federation. ↵Simon MacMullen2013-07-051-26/+29
| | | | | | | | | | | | | | | | | | | | This is still a bit ugly, bits of queue state leak out in the events at the moment, and events are still exactly those needed by federation rather than a carefully thought out set. But it works.
| | | | * Start of queue decorators.Simon MacMullen2013-07-051-1/+1
| | | | |
| | | | * Merge in defaultSimon MacMullen2013-07-051-29/+63
| | | | |\
| | | | | * API change.Simon MacMullen2013-07-011-1/+0
| | | | | |
| | | | | * Ensure that if we fail over / reconfigure federation while running, we ask ↵Simon MacMullen2013-07-011-0/+4
| | | | | | | | | | | | | | | | | | | | | | | | the qproc to remoind us what our running state is.
| | | | | * More consistent and correct nomenclature.Simon MacMullen2013-07-011-2/+2
| | | | | |
| | | | | * OopsSimon MacMullen2013-06-281-1/+2
| | | | | |
| | | | | * TODO-- yes it could be faster.Simon MacMullen2013-06-261-4/+1
| | | | | |
| | | | | * Convert the x-purpose hack into a bit less of a hack: consumer priorities.Simon MacMullen2013-06-261-44/+36
| | | | | |
| | | | | * Merge in defaultSimon MacMullen2013-06-241-6/+47
| | | | | |\
| | | | | | * Inform fed queues of policy change and termination, and abstract startup a ↵Simon MacMullen2013-06-031-5/+3
| | | | | | | | | | | | | | | | | | | | | | | | | | | | bit more.
| | | | | | * If we have local active consumers, ignore federated ones.Simon MacMullen2013-05-241-7/+20
| | | | | | |
| | | | | | * Make sure we update the federation state when a consumer becomes inactive or ↵Simon MacMullen2013-05-241-5/+15
| | | | | | | | | | | | | | | | | | | | | | | | | | | | is cancelled.
| | | | | | * Tell the federated queue about basic.get.Simon MacMullen2013-05-231-1/+2
| | | | | | |
| | | | | | * Rename thisSimon MacMullen2013-05-231-1/+1
| | | | | | |
| | | | | | * Distinguish between federated consumers and others.Simon MacMullen2013-05-231-4/+15
| | | | | | |
| | | | | | * Only consume if we are empty.Simon MacMullen2013-05-221-4/+5
| | | | | | |
| | | | | | * Quick and dirty hooks for federated queues.Simon MacMullen2013-05-151-2/+9
| | | | | | |
* | | | | | | Dead lettering by policy.Simon MacMullen2013-09-031-12/+28
|/ / / / / /
View Lorry Controller Status