From a787737f9ad6656e7da382b35c49ecf622900bf0 Mon Sep 17 00:00:00 2001 From: Amey Barve Date: Wed, 10 May 2017 14:47:30 +0530 Subject: [PATCH] GEODE-2890: Corrected debug log location in AbstractGatewaySenderEventProcessor.processQueue(). --- .../cache/wan/AbstractGatewaySenderEventProcessor.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java index 263c446dd81f..30b61adda06d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java @@ -551,13 +551,13 @@ protected void processQueue() { BucketRegion bucket = qpr.getDataStore().getLocalBucketById(bucketId); if (bucket == null || !bucket.getBucketAdvisor().isPrimary()) { event.setPossibleDuplicate(true); + if (isDebugEnabled) { + logger.debug( + "Bucket id: {} is no longer primary on this node. The event: {} will be dispatched from this node with possibleDuplicate set to true.", + bucketId, event); + } } } - if (isDebugEnabled) { - logger.debug( - "Bucket id: {} is no longer primary on this node. The event {} will be dispatched from this node with possibleDuplicate set to true.", - bucketId, event); - } } }