| Commit message (Expand) | Author | Age | Files | Lines |
* | Further refactoringbug25625 | Emile Joubert | 2013-07-02 | 1 | -9/+9 |
* | Refactor | Emile Joubert | 2013-07-01 | 1 | -4/+5 |
* | Correction and contraction | Emile Joubert | 2013-07-01 | 1 | -3/+2 |
* | Optimisation for handling discarded deliveries | Emile Joubert | 2013-06-27 | 1 | -15/+7 |
* | Stem leak when master deals with discarded messages | Emile Joubert | 2013-06-27 | 1 | -11/+9 |
* | stable to default | Simon MacMullen | 2013-01-24 | 1 | -1/+1 |
|\ |
|
| * | Update copyright 2013bug25343 | Emile Joubert | 2013-01-23 | 1 | -1/+1 |
* | | add BQ:purge_acks/1 | Matthias Radestock | 2013-01-19 | 1 | -1/+3 |
* | | Merge in bug24407. | Simon MacMullen | 2013-01-04 | 1 | -5/+8 |
|\ \ |
|
| * | | better fun names | Matthias Radestock | 2013-01-01 | 1 | -2/+2 |
| * | | Ensure rabbitmqctl list_queues remains responsive during sync, and emit stats... | Simon MacMullen | 2012-12-14 | 1 | -3/+5 |
* | | | merge default into bug24407 | Matthias Radestock | 2013-01-03 | 1 | -48/+42 |
|\ \ \ |
|
| * | | | replace bq:foreach_ack with a more versatile ackfold | Matthias Radestock | 2013-01-01 | 1 | -7/+8 |
| * | | | merge default into bug25328 | Matthias Radestock | 2012-11-30 | 1 | -13/+21 |
| |\ \ \ |
|
| | * | | | return to a simpler, better BQ:dropwhile, and introduce 'fetchwhile' | Matthias Radestock | 2012-11-29 | 1 | -19/+27 |
| * | | | | remove unused state var | Matthias Radestock | 2012-11-30 | 1 | -29/+14 |
| |/ / / |
|
* | | | | Specs. | Simon MacMullen | 2013-01-03 | 1 | -0/+2 |
| |/ /
|/| | |
|
* | | | Make syncing idempotent. | Simon MacMullen | 2012-12-06 | 1 | -1/+1 |
* | | | Add rabbitmqctl sync_queue, and make it synchronous. Also fix the fact that w... | Simon MacMullen | 2012-12-06 | 1 | -5/+6 |
* | | | extract logging | Matthias Radestock | 2012-11-29 | 1 | -8/+9 |
* | | | Make sure newly-started slaves don't respond and confuse things. | Simon MacMullen | 2012-11-29 | 1 | -1/+1 |
* | | | Only respond to 'EXIT's from parent / syncer. | Simon MacMullen | 2012-11-29 | 1 | -4/+7 |
* | | | Have slaves determine whether they need sync. | Simon MacMullen | 2012-11-29 | 1 | -17/+9 |
* | | | Oops, didn't even compile that last one. | Simon MacMullen | 2012-11-29 | 1 | -5/+8 |
* | | | cosmetic | Matthias Radestock | 2012-11-28 | 1 | -15/+13 |
* | | | Diagram. | Simon MacMullen | 2012-11-28 | 1 | -2/+0 |
* | | | Don't expose the BQ to the syncer. | Simon MacMullen | 2012-11-28 | 1 | -2/+2 |
* | | | Spawn a separate process to send out messages from the master. This lets us s... | Simon MacMullen | 2012-11-28 | 1 | -2/+3 |
* | | | Various QA cleanups | Simon MacMullen | 2012-11-28 | 1 | -22/+31 |
* | | | merge default into bug24407 | Matthias Radestock | 2012-11-27 | 1 | -1/+19 |
|\ \ \
| |/ /
|/| | |
|
| * | | Move the sync stuff to its own module | Simon MacMullen | 2012-11-26 | 1 | -72/+1 |
| * | | Don't hang on shutdown | Simon MacMullen | 2012-11-26 | 1 | -0/+6 |
| * | | Merge in default | Simon MacMullen | 2012-11-26 | 1 | -1/+84 |
| |\ \ |
|
| | * | | Improve progfess logging. | Simon MacMullen | 2012-11-26 | 1 | -14/+18 |
| | * | | Send the sync_start over GM to flush out any other messages that we might hav... | Simon MacMullen | 2012-11-26 | 1 | -2/+5 |
| | * | | Fix bugs in previous commit, and be rather more thorough about monitoring and... | Simon MacMullen | 2012-11-26 | 1 | -22/+43 |
| | * | | Add spec, fix API, refuse to run if there are pending acks, return status, do... | Simon MacMullen | 2012-11-26 | 1 | -6/+6 |
| | * | | Fix expiry | Simon MacMullen | 2012-11-23 | 1 | -2/+2 |
| | * | | Merge bug25303 | Simon MacMullen | 2012-11-23 | 1 | -1/+56 |
| | |\ \ |
|
| | | * | | Flow control for the sync process. | Simon MacMullen | 2012-11-23 | 1 | -1/+14 |
| | | * | | Log progress, and an important optimisation. | Simon MacMullen | 2012-11-23 | 1 | -7/+22 |
| | | * | | Eager mirror synchronisation. | Simon MacMullen | 2012-11-23 | 1 | -1/+28 |
* | | | | | mark all messages enqueued in the slave as 'delivered'bug25323 | Matthias Radestock | 2012-11-26 | 1 | -26/+13 |
|/ / / / |
|
* | | | | merge bug25303 into default | Matthias Radestock | 2012-11-23 | 1 | -1/+6 |
|\ \ \ \
| |/ / / |
|
| * | | | Propagate API change | Emile Joubert | 2012-11-23 | 1 | -1/+6 |
| |/ / |
|
* | | | Merged bug25315 | Emile Joubert | 2012-11-23 | 1 | -4/+4 |
|\ \ \
| |/ / |
|
| * | | Rename backing queue foldbug25314 | Emile Joubert | 2012-11-22 | 1 | -4/+4 |
* | | | bq api tweak: don't include remaining message count in fetch/drop result | Matthias Radestock | 2012-11-22 | 1 | -17/+14 |
|/ / |
|
* | | introduce bq:drop/2 and use it in slaves to prevent msg fetching | Matthias Radestock | 2012-11-20 | 1 | -10/+28 |
|/ |
|
* | HA optimisation: don't broadcast 'drop' when nothing has been dropped | Matthias Radestock | 2012-10-31 | 1 | -1/+4 |