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 <lhughesgodf...@pivotal.io> Authored: Wed May 24 14:27:25 2017 -0700 Committer: Lynn Hughes-Godfrey <lhughesgodf...@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>();
