diff options
Diffstat (limited to 'src')
| -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; _ -> |