summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* 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 bug25321 into stableTim Watson2012-12-030-0/+0
| |\
| * \ merge defaultbug25321Tim Watson2012-12-035-38/+31
| |\ \ | | |/
| * | 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 bug25309 into stableTim Watson2012-11-265-38/+31
|\ \ | |/ |/|
| * 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
| | | |
| * | | merge bug25301 into stableMatthias Radestock2012-11-221-2/+4
| |\ \ \ | | |/ / | |/| |
| | * | 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
| * recover for accidental merge with defaultTim Watson2012-11-261-1/+1
| |
| * 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
|/
* create 'stable' branchMatthias Radestock2012-11-200-0/+0
|
* Changelogs for 3.0.0rabbitmq_v3_0_0Simon MacMullen2012-11-192-0/+9
|
* merge bug25297 into defaultMatthias Radestock2012-11-161-1/+1
|\
| * 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.
* | refactor: extract some helpersMatthias Radestock2012-11-161-14/+16
| | | | | | | | | | ...to make it abundantly clear which queue operations amount to an ack/requeue.
* | refactor: simplify dlx logic top halfMatthias Radestock2012-11-161-30/+20
| |
* | cosmeticMatthias Radestock2012-11-161-2/+2
| |
* | cosmeticMatthias Radestock2012-11-151-24/+13
| |
* | inline (and avoid misleading var name in the process)Matthias Radestock2012-11-151-2/+2
|/
* refactor stats recording in channelMatthias Radestock2012-11-151-35/+29
| | | | | | - specify stats type explicitly rather than inferring it from the structure of the key (yuck!) - s/maybe_incr_stats/incr_stats
* inlineMatthias Radestock2012-11-151-6/+4
|
* Work on older Erlang versionsSimon MacMullen2012-11-142-5/+8
|
* Merge bug25251 (very late!)Simon MacMullen2012-11-131-11/+2
|\
| * Merge in defaultbug25251Simon MacMullen2012-11-1329-602/+885
| |\ | |/ |/|
* | merge bug24915 into defaultMatthias Radestock2012-11-132-6/+14
|\ \
| * \ merge headsMatthias Radestock2012-11-131-0/+3
| |\ \
| | * | test triggering of memory alarmsMatthias Radestock2012-11-131-0/+3
| | | |
| * | | Merge bug25178Simon MacMullen2012-11-130-0/+0
| |\ \ \ | | |/ /
| * | | And, err, this thing isn't needed any more.bug25178Simon MacMullen2012-11-131-49/+0
| | | |
| * | | Explain whySimon MacMullen2012-11-131-0/+4
| | | |
| * | | rabbit_node_monitor traps exits, so shutdown allows us time to flush anyTim Watson2012-11-131-0/+1
| | | | | | | | | | | | | | | | pending file system operations before the process dies
View Lorry Controller Status