summaryrefslogtreecommitdiff
path: root/src
Commit message (Collapse)AuthorAgeFilesLines
* Update copyright 2013bug25343Emile Joubert2013-01-23122-122/+122
|
* one test writer is quite enough. and make it work.bug25360Matthias Radestock2013-01-221-10/+8
|
* our test writer needs to do a bit more nowMatthias Radestock2013-01-221-1/+8
|
* get the channel to flush the writerMatthias Radestock2013-01-212-8/+19
| | | | when the former is asked to terminate by the reader
* Backed out changeset 0ca8cbef9720Matthias Radestock2013-01-212-19/+8
| | | | accidentally committed on 'stable' instead of bug25360 branch
* get th channel to flush the writerMatthias Radestock2013-01-212-8/+19
| | | | when the former is asked to terminate by the reader
* Prevent explosion if someone passes a list.bug25401Simon MacMullen2013-01-161-4/+9
|
* merge bug25353 into stableMatthias Radestock2013-01-081-1/+1
|\
| * merge bug25353 into stableMatthias Radestock2013-01-081-1/+1
| |\
| | * correct and/or confusionbug25378Matthias Radestock2013-01-041-1/+1
| | |
* | | tidy upbug25353Matthias Radestock2013-01-081-4/+0
|/ /
* | copy change from rabbit_amqqueue_process to slaveMatthias Radestock2013-01-081-7/+9
|/ | | | for consistency
* ReminderSimon MacMullen2012-12-121-0/+2
|
* make sure the stats and rate timers don't keep each other aliveMatthias Radestock2012-12-111-18/+10
|
* Those catches do no really do anything.bug25351Simon MacMullen2012-12-101-2/+2
|
* Call application_master:get_child/1 more like OTP does.Simon MacMullen2012-12-101-2/+3
|
* application_controller:get_master/1 can return 'undefined'.Simon MacMullen2012-12-101-4/+6
|
* Merge bug25330Emile Joubert2012-12-053-3/+40
|\
| * Tweak the regex, align, and a test.bug25330Simon MacMullen2012-12-052-2/+13
| |
| * Special case the 3.0.0 version check.Simon MacMullen2012-12-051-4/+11
| |
| * Move the version check fun to misc, and anchor the regex.Simon MacMullen2012-12-052-10/+13
| |
| * Compare RabbitMQ versions ignoring the "patch" version (as semver.org calls ↵Simon MacMullen2012-12-031-6/+22
| | | | | | | | it). Not that we are full on semver, but close enough.
* | merge bug25341 into stableMatthias Radestock2012-12-051-1/+9
|\ \
| * | Don't blow up if we end up talking to not-a-supervisor.bug25341Simon MacMullen2012-12-051-1/+9
| | |
* | | reduce wrongnessbug25340Matthias Radestock2012-12-041-2/+1
| | |
* | | Send messages immediately if we are not busy.Simon MacMullen2012-12-041-2/+9
|/ /
* | Merge bug25335Simon MacMullen2012-12-041-1/+5
|\ \ | |/
| * merge defaultbug25321Tim Watson2012-12-034-37/+30
| |\
| * | Wake up all queues after policy change.Simon MacMullen2012-11-231-1/+5
| | |
* | | get rid of last remaining cross-node fun in rabbit_amqqueuebug25335Matthias Radestock2012-12-031-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 delegateMatthias Radestock2012-12-032-39/+32
| |/ |/| | | | | since the latter changes less frequently
* | merge stable into bug25309bug25309Tim Watson2012-11-263-25/+42
|\ \ | |/
| * Merge bug25305Simon MacMullen2012-11-223-13/+24
| |\
| | * Merged bug25306Emile Joubert2012-11-222-11/+20
| | |\
| | | * leave the ram_msg_count unchanged in BQ:foldbug25306Matthias Radestock2012-11-221-5/+7
| | | | | | | | | | | | | | | | since we are not moving messages *into the queue*
| | | * add test for invoking bq:fold when messages are on diskMatthias Radestock2012-11-211-0/+7
| | | |
| | | * assert after foldMatthias Radestock2012-11-211-7/+6
| | | |
| | | * assertionMatthias Radestock2012-11-201-0/+1
| | | |
| | * | branch from stable, expire messages eagerlybug25301Tim Watson2012-11-211-2/+4
| | |/
| * | ack unroutable dead-lettered messages straight awaybug25305Matthias Radestock2012-11-201-12/+18
| |/ | | | | | | thus plugging a leak
* | Fix a race where we decide on the BQ before writing the #amqqueue{} to ↵Simon MacMullen2012-11-221-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 MacMullen2012-11-211-2/+2
| |
* | Useful guard.Simon MacMullen2012-11-211-1/+1
| |
* | Don't try to assert result of {add,drop}_mirror.Simon MacMullen2012-11-211-11/+3
| |
* | Make start/stop mirroring into a cast not a call.Simon MacMullen2012-11-212-19/+19
|/
* plug leakbug25297Matthias Radestock2012-11-161-1/+1
|
* fixmeMatthias Radestock2012-11-161-1/+2
|
* refactor stop_laterMatthias Radestock2012-11-161-18/+15
| | | | | | - s/stop_later/stop - since it's always called with Reason=normal there is no point passing that around / storing it
* Merge bug25295Simon MacMullen2012-11-161-4/+5
|\
| * always monitor queues from which we are (possibly) delivering messagesbug25295Matthias Radestock2012-11-151-4/+5
| | | | | | | | | | so that stats associated with these queues are cleared out from the channel's process dictionary when these queues disappear.
View Lorry Controller Status