You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by la...@apache.org on 2018/12/17 21:50:57 UTC
[geode] 03/04: GEODE-6177: Spotless
This is an automated email from the ASF dual-hosted git repository.
ladyvader pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 14fee9aaa1e1fe82cc0adfce98df29521279e981
Author: Ryan McMahon <rm...@pivotal.io>
AuthorDate: Fri Dec 14 16:51:52 2018 -0800
GEODE-6177: Spotless
---
.../cache/wan/misc/NewWanAuthenticationDUnitTest.java | 13 ++++++++-----
.../cache/wan/GatewaySenderEventRemoteDispatcher.java | 3 ++-
2 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/misc/NewWanAuthenticationDUnitTest.java b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/misc/NewWanAuthenticationDUnitTest.java
index c4cb5f2..48d5be9 100644
--- a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/misc/NewWanAuthenticationDUnitTest.java
+++ b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/misc/NewWanAuthenticationDUnitTest.java
@@ -407,10 +407,12 @@ public class NewWanAuthenticationDUnitTest extends WANTestBase {
// sender.invoke(() -> verifyDifferentServerInGetCredentialCall());
}
- private void doPutsAndVerifyQueueSizeAfterProcessing(final String regionName, final int numPuts,
- final boolean shouldBeConnected,
- final boolean isQueueBlocked,
- final boolean isAckThreadRunning) {
+ private void doPutsAndVerifyQueueSizeAfterProcessing(
+ final String regionName,
+ final int numPuts,
+ final boolean shouldBeConnected,
+ final boolean isQueueBlocked,
+ final boolean isAckThreadRunning) {
if (isQueueBlocked) {
// caller is assuming that queue processing will not make progress
try {
@@ -442,7 +444,8 @@ public class NewWanAuthenticationDUnitTest extends WANTestBase {
checkQueueSize(senderId, numPuts);
} finally {
- GatewaySenderEventRemoteDispatcher.messageProcessingAttempted = isAck -> {};
+ GatewaySenderEventRemoteDispatcher.messageProcessingAttempted = isAck -> {
+ };
}
} else {
doPuts(regionName, numPuts);
diff --git a/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java b/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java
index eda2865..3b3318f 100644
--- a/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java
+++ b/geode-wan/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java
@@ -67,7 +67,8 @@ public class GatewaySenderEventRemoteDispatcher implements GatewaySenderEventDis
* Without this hook, negative tests, can't ensure that message processing was
* attempted, so they wouldn't know how long to wait for some sort of failure.
*/
- public static Consumer<Boolean> messageProcessingAttempted = isAck -> {};
+ public static Consumer<Boolean> messageProcessingAttempted = isAck -> {
+ };
/**
* This count is reset to 0 each time a successful connection is made.