Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | tidy upbug25353 | Matthias Radestock | 2013-01-08 | 1 | -4/+0 |
| | |||||
* | copy change from rabbit_amqqueue_process to slave | Matthias Radestock | 2013-01-08 | 1 | -7/+9 |
| | | | | for consistency | ||||
* | Reminder | Simon MacMullen | 2012-12-12 | 1 | -0/+2 |
| | |||||
* | make sure the stats and rate timers don't keep each other alive | Matthias Radestock | 2012-12-11 | 1 | -18/+10 |
| | |||||
* | Those catches do no really do anything.bug25351 | Simon MacMullen | 2012-12-10 | 1 | -2/+2 |
| | |||||
* | Call application_master:get_child/1 more like OTP does. | Simon MacMullen | 2012-12-10 | 1 | -2/+3 |
| | |||||
* | application_controller:get_master/1 can return 'undefined'. | Simon MacMullen | 2012-12-10 | 1 | -4/+6 |
| | |||||
* | Merge bug25330 | Emile Joubert | 2012-12-05 | 3 | -3/+40 |
|\ | |||||
| * | Tweak the regex, align, and a test.bug25330 | Simon MacMullen | 2012-12-05 | 2 | -2/+13 |
| | | |||||
| * | Special case the 3.0.0 version check. | Simon MacMullen | 2012-12-05 | 1 | -4/+11 |
| | | |||||
| * | Move the version check fun to misc, and anchor the regex. | Simon MacMullen | 2012-12-05 | 2 | -10/+13 |
| | | |||||
| * | Compare RabbitMQ versions ignoring the "patch" version (as semver.org calls ↵ | Simon MacMullen | 2012-12-03 | 1 | -6/+22 |
| | | | | | | | | it). Not that we are full on semver, but close enough. | ||||
* | | merge bug25341 into stable | Matthias Radestock | 2012-12-05 | 1 | -1/+9 |
|\ \ | |||||
| * | | Don't blow up if we end up talking to not-a-supervisor.bug25341 | Simon MacMullen | 2012-12-05 | 1 | -1/+9 |
| | | | |||||
* | | | reduce wrongnessbug25340 | Matthias Radestock | 2012-12-04 | 1 | -2/+1 |
| | | | |||||
* | | | Send messages immediately if we are not busy. | Simon MacMullen | 2012-12-04 | 1 | -2/+9 |
|/ / | |||||
* | | Merge bug25335 | Simon MacMullen | 2012-12-04 | 1 | -1/+5 |
|\ \ | |/ | |||||
| * | merge defaultbug25321 | Tim Watson | 2012-12-03 | 4 | -37/+30 |
| |\ | |||||
| * | | Wake up all queues after policy change. | Simon MacMullen | 2012-11-23 | 1 | -1/+5 |
| | | | |||||
* | | | get rid of last remaining cross-node fun in rabbit_amqqueuebug25335 | Matthias Radestock | 2012-12-03 | 1 | -17/+8 |
| | | | | | | | | | | | | | | | | | | | | | | | | There was no need for the rabbit_misc:with_exit_handler in safe_delegate_call_ok, since the error condition caught be that is also being caught by the check in 'filter'. Getting rid of the superfluous check allows us to just invoke delegate:call and thus get rid of the funs. Plus inline the lot. | ||||
* | | | move generic cross-node funs from rabbit_amqqueue to delegate | Matthias Radestock | 2012-12-03 | 2 | -39/+32 |
| |/ |/| | | | | | since the latter changes less frequently | ||||
* | | merge stable into bug25309bug25309 | Tim Watson | 2012-11-26 | 3 | -25/+42 |
|\ \ | |/ | |||||
| * | Merge bug25305 | Simon MacMullen | 2012-11-22 | 3 | -13/+24 |
| |\ | |||||
| | * | Merged bug25306 | Emile Joubert | 2012-11-22 | 2 | -11/+20 |
| | |\ | |||||
| | | * | leave the ram_msg_count unchanged in BQ:foldbug25306 | Matthias Radestock | 2012-11-22 | 1 | -5/+7 |
| | | | | | | | | | | | | | | | | since we are not moving messages *into the queue* | ||||
| | | * | add test for invoking bq:fold when messages are on disk | Matthias Radestock | 2012-11-21 | 1 | -0/+7 |
| | | | | |||||
| | | * | assert after fold | Matthias Radestock | 2012-11-21 | 1 | -7/+6 |
| | | | | |||||
| | | * | assertion | Matthias Radestock | 2012-11-20 | 1 | -0/+1 |
| | | | | |||||
| | * | | branch from stable, expire messages eagerlybug25301 | Tim Watson | 2012-11-21 | 1 | -2/+4 |
| | |/ | |||||
| * | | ack unroutable dead-lettered messages straight awaybug25305 | Matthias Radestock | 2012-11-20 | 1 | -12/+18 |
| |/ | | | | | | | thus plugging a leak | ||||
* | | Fix a race where we decide on the BQ before writing the #amqqueue{} to ↵ | Simon MacMullen | 2012-11-22 | 1 | -4/+5 |
| | | | | | | | | Mnesia, then the policy changes and we are therefore not notified. We now only make the initial decision after we can be assured we will be informed of subsequent changes. | ||||
* | | Carry on if an individual notification fails. | Simon MacMullen | 2012-11-21 | 1 | -2/+2 |
| | | |||||
* | | Useful guard. | Simon MacMullen | 2012-11-21 | 1 | -1/+1 |
| | | |||||
* | | Don't try to assert result of {add,drop}_mirror. | Simon MacMullen | 2012-11-21 | 1 | -11/+3 |
| | | |||||
* | | Make start/stop mirroring into a cast not a call. | Simon MacMullen | 2012-11-21 | 2 | -19/+19 |
|/ | |||||
* | plug leakbug25297 | Matthias Radestock | 2012-11-16 | 1 | -1/+1 |
| | |||||
* | fixme | Matthias Radestock | 2012-11-16 | 1 | -1/+2 |
| | |||||
* | refactor stop_later | Matthias Radestock | 2012-11-16 | 1 | -18/+15 |
| | | | | | | - s/stop_later/stop - since it's always called with Reason=normal there is no point passing that around / storing it | ||||
* | Merge bug25295 | Simon MacMullen | 2012-11-16 | 1 | -4/+5 |
|\ | |||||
| * | always monitor queues from which we are (possibly) delivering messagesbug25295 | Matthias Radestock | 2012-11-15 | 1 | -4/+5 |
| | | | | | | | | | | so that stats associated with these queues are cleared out from the channel's process dictionary when these queues disappear. | ||||
* | | refactor: extract some helpers | Matthias Radestock | 2012-11-16 | 1 | -14/+16 |
| | | | | | | | | | | ...to make it abundantly clear which queue operations amount to an ack/requeue. | ||||
* | | refactor: simplify dlx logic top half | Matthias Radestock | 2012-11-16 | 1 | -30/+20 |
| | | |||||
* | | cosmetic | Matthias Radestock | 2012-11-16 | 1 | -2/+2 |
| | | |||||
* | | cosmetic | Matthias Radestock | 2012-11-15 | 1 | -24/+13 |
| | | |||||
* | | inline (and avoid misleading var name in the process) | Matthias Radestock | 2012-11-15 | 1 | -2/+2 |
|/ | |||||
* | refactor stats recording in channel | Matthias Radestock | 2012-11-15 | 1 | -35/+29 |
| | | | | | | - specify stats type explicitly rather than inferring it from the structure of the key (yuck!) - s/maybe_incr_stats/incr_stats | ||||
* | inline | Matthias Radestock | 2012-11-15 | 1 | -6/+4 |
| | |||||
* | Work on older Erlang versions | Simon MacMullen | 2012-11-14 | 2 | -5/+8 |
| | |||||
* | Merge in defaultbug25251 | Simon MacMullen | 2012-11-13 | 24 | -535/+761 |
|\ | |||||
| * | merge bug24915 into default | Matthias Radestock | 2012-11-13 | 2 | -6/+14 |
| |\ |