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 2017/05/24 21:27:58 UTC
geode git commit: Spotless changes
Repository: geode
Updated Branches:
refs/heads/feature/close_cache_aeq_enqueue 4c02fe35c -> b7d0ec7d3
Spotless changes
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/b7d0ec7d
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/b7d0ec7d
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/b7d0ec7d
Branch: refs/heads/feature/close_cache_aeq_enqueue
Commit: b7d0ec7d3caba732d53167ebcec7925a1e6806e5
Parents: 4c02fe3
Author: Lynn Hughes-Godfrey <lh...@pivotal.io>
Authored: Wed May 24 14:27:25 2017 -0700
Committer: Lynn Hughes-Godfrey <lh...@pivotal.io>
Committed: Wed May 24 14:27:25 2017 -0700
----------------------------------------------------------------------
.../asyncqueue/AsyncEventListenerDUnitTest.java | 94 ++++++++++----------
1 file changed, 47 insertions(+), 47 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/b7d0ec7d/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
index 7799216..795af36 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
@@ -1718,32 +1718,32 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
Region r = cache.getRegion(Region.SEPARATOR + getTestMethodName() + "_PR");
r.put(1, 1);
r.put(2, 2);
- //This will trigger the gateway event filter to close the cache
+ // This will trigger the gateway event filter to close the cache
try {
r.removeAll(Collections.singleton(1));
fail("Should have received a partition offline exception");
- } catch(PartitionOfflineException expected) {
-
+ } catch (PartitionOfflineException expected) {
+
}
});
}
-private void createPersistentPartitionRegion() {
- AttributesFactory fact = new AttributesFactory();
+ private void createPersistentPartitionRegion() {
+ AttributesFactory fact = new AttributesFactory();
- PartitionAttributesFactory pfact = new PartitionAttributesFactory();
- pfact.setTotalNumBuckets(16);
- fact.setPartitionAttributes(pfact.create());
- fact.setDataPolicy(DataPolicy.PERSISTENT_PARTITION);
- fact.setOffHeap(isOffHeap());
- Region r = cache.createRegionFactory(fact.create()).addAsyncEventQueueId("ln")
- .create(getTestMethodName() + "_PR");
-}
+ PartitionAttributesFactory pfact = new PartitionAttributesFactory();
+ pfact.setTotalNumBuckets(16);
+ fact.setPartitionAttributes(pfact.create());
+ fact.setDataPolicy(DataPolicy.PERSISTENT_PARTITION);
+ fact.setOffHeap(isOffHeap());
+ Region r = cache.createRegionFactory(fact.create()).addAsyncEventQueueId("ln")
+ .create(getTestMethodName() + "_PR");
+ }
-private void addAEQWithCacheCloseFilter() {
- cache.createAsyncEventQueueFactory().addGatewayEventFilter(new CloseCacheGatewayFilter()).setPersistent(true).setParallel(true)
- .create("ln", new MyAsyncEventListener());
-}
+ private void addAEQWithCacheCloseFilter() {
+ cache.createAsyncEventQueueFactory().addGatewayEventFilter(new CloseCacheGatewayFilter())
+ .setPersistent(true).setParallel(true).create("ln", new MyAsyncEventListener());
+ }
private static Set<Object> getKeysSeen(VM vm, String asyncEventQueueId) {
return vm.invoke(() -> {
@@ -1762,37 +1762,37 @@ private void addAEQWithCacheCloseFilter() {
}
private final class CloseCacheGatewayFilter implements GatewayEventFilter {
- @Override
- public boolean beforeEnqueue(final GatewayQueueEvent event) {
- if (event.getOperation().isRemoveAll()) {
- new Thread(() -> cache.close()).start();
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- // ignore
- }
- throw new CacheClosedException();
- }
- return true;
- }
-
- @Override
- public boolean beforeTransmit(final GatewayQueueEvent event) {
- return false;
- }
-
- @Override
- public void afterAcknowledgement(final GatewayQueueEvent event) {
-
- }
-
- @Override
- public void close() {
-
- }
-}
+ @Override
+ public boolean beforeEnqueue(final GatewayQueueEvent event) {
+ if (event.getOperation().isRemoveAll()) {
+ new Thread(() -> cache.close()).start();
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ // ignore
+ }
+ throw new CacheClosedException();
+ }
+ return true;
+ }
+
+ @Override
+ public boolean beforeTransmit(final GatewayQueueEvent event) {
+ return false;
+ }
+
+ @Override
+ public void afterAcknowledgement(final GatewayQueueEvent event) {
+
+ }
+
+ @Override
+ public void close() {
+
+ }
+ }
-private static class BucketMovingAsyncEventListener implements AsyncEventListener {
+ private static class BucketMovingAsyncEventListener implements AsyncEventListener {
private final DistributedMember destination;
private boolean moved;
private Set<Object> keysSeen = new HashSet<Object>();