diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-04 23:40:43 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-05 00:26:41 +0200 |
| commit | 474520d049be58a0049b47a70cfe1c4a255ca248 (patch) | |
| tree | fd12e0238de4e59451e631c4d65bdfc71d388744 | |
| parent | 7cdd8c725ba484e40e55322c0066673196e08709 (diff) | |
| download | rabbitmq-server-git-474520d049be58a0049b47a70cfe1c4a255ca248.tar.gz | |
fixes retrieving sync_batch_size from policy
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 7e7a13043d..7b6c259e99 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -370,6 +370,8 @@ maybe_auto_sync(Q = #amqqueue{pid = QPid}) -> sync_batch_size(#amqqueue{} = Q) -> case policy(<<"ha-sync-batch-size">>, Q) of + none -> %% we need this case because none > 1 == true + ?DEFAULT_BATCH_SIZE; BatchSize when BatchSize > 1 -> BatchSize; _ -> |