summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Expand)AuthorAgeFilesLines
* Don't return consumer utilisation when idle or there are no consumers; no num...bug25882Simon MacMullen2013-11-201-6/+16
* Simplify and remove magic numbers from the i/2 bit by treating time since las...Simon MacMullen2013-11-191-35/+23
* Cosmetic / unused variables.Simon MacMullen2013-11-151-4/+4
* Simplify: less state, less records, more pattern matching.Simon MacMullen2013-11-151-47/+33
* Store timestamps as integers.Simon MacMullen2013-11-151-11/+11
* Missed one + cosmetic.Simon MacMullen2013-11-151-10/+10
* CU for "Consumer Utilisation" not CB for "Consumer Bound".Simon MacMullen2013-11-151-15/+15
* Maintain an exponential moving average of the utilisation.Simon MacMullen2013-11-151-30/+43
* Experiment with the idea of "consumer utilisation". Still far too lumpy.Simon MacMullen2013-11-141-18/+57
* consumer_bound info item.Simon MacMullen2013-11-141-9/+14
* 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 var...bug25757Simon MacMullen2013-09-111-7/+1
| | | * Introduce a new return code for this case, since {new, Q} is going to mess up...Simon MacMullen2013-09-091-5/+1
| | | * 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
* | | Version TTL and expiry messages, and ignore the wrong ones. Also stop timers ...Simon MacMullen2013-09-111-13/+29
* | | 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 qu...Simon MacMullen2013-08-211-3/+3
| | | * | Notify "startup" when we fail over too, that means the federation links will ...Simon MacMullen2013-08-211-3/+5
| | | * | Slightly clearer?Simon MacMullen2013-08-211-10/+10
| | | * | Small changes: Don't reevaluate consumer priority on every delivery, refactor...Simon MacMullen2013-08-211-15/+14
| | | * | 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 basic....Simon MacMullen2013-07-241-2/+9
| | | | * 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. T...Simon MacMullen2013-07-051-26/+29
| | | | * 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 th...Simon MacMullen2013-07-011-0/+4
| | | | | * 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 bi...Simon MacMullen2013-06-031-5/+3
| | | | | | * 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
| | | | | | * Tell the federated queue about basic.get.Simon MacMullen2013-05-231-1/+2
| | | | | | * Rename thisSimon MacMullen2013-05-231-1/+1