This is an automated email from the ASF dual-hosted git repository.
udo pushed a commit to branch feature/GEODE-4685
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-4685 by this
push:
new 402e063 GEODE-4685: spotless
402e063 is described below
commit 402e063ed4280fc41bfbe9578fdc0ee4edae6f97
Author: Udo <[email protected]>
AuthorDate: Mon Feb 26 16:59:16 2018 -0800
GEODE-4685: spotless
---
.../geode/connectors/jdbc/JdbcAsyncWriter.java | 1 +
.../geode/connectors/jdbc/JdbcAsyncWriterTest.java | 4 +-
.../geode/connectors/jdbc/JdbcWriterTest.java | 4 +-
.../BaseLineAndCompareQueryPerfJUnitTest.java | 3 +-
.../geode/cache/query/PdxStringQueryJUnitTest.java | 12 +--
.../cache/query/dunit/PdxStringQueryDUnitTest.java | 87 +++++++++-------------
.../geode/internal/PdxDeleteFieldJUnitTest.java | 2 +-
.../lucene/internal/IndexRepositoryFactory.java | 2 +-
.../internal/LuceneEventListenerJUnitTest.java | 33 ++++----
9 files changed, 66 insertions(+), 82 deletions(-)
diff --git
a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriter.java
b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriter.java
index 7f09d48..8d68c95 100644
---
a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriter.java
+++
b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriter.java
@@ -32,6 +32,7 @@ import org.apache.geode.pdx.PdxInstance;
/**
* This class provides write behind cache semantics for a JDBC data source
using AsyncEventListener.
+ *
* @since Geode 1.4
*/
@Experimental
diff --git
a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriterTest.java
b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriterTest.java
index ef7665c..0e5c8de 100644
---
a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriterTest.java
+++
b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriterTest.java
@@ -27,15 +27,15 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
-import org.apache.geode.cache.Cache;
-import org.apache.geode.test.fake.Fakes;
import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.apache.geode.cache.Cache;
import org.apache.geode.cache.asyncqueue.AsyncEvent;
import org.apache.geode.connectors.jdbc.internal.SqlHandler;
import org.apache.geode.internal.cache.InternalRegion;
+import org.apache.geode.test.fake.Fakes;
import org.apache.geode.test.junit.categories.UnitTest;
@Category(UnitTest.class)
diff --git
a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcWriterTest.java
b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcWriterTest.java
index c6438b9..92a58a4 100644
---
a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcWriterTest.java
+++
b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcWriterTest.java
@@ -23,18 +23,18 @@ import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyZeroInteractions;
import static org.mockito.Mockito.when;
-import org.apache.geode.cache.Cache;
-import org.apache.geode.test.fake.Fakes;
import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.apache.geode.cache.Cache;
import org.apache.geode.cache.EntryEvent;
import org.apache.geode.cache.RegionEvent;
import org.apache.geode.cache.SerializedCacheValue;
import org.apache.geode.connectors.jdbc.internal.SqlHandler;
import org.apache.geode.internal.cache.InternalRegion;
import org.apache.geode.pdx.PdxInstance;
+import org.apache.geode.test.fake.Fakes;
import org.apache.geode.test.junit.categories.UnitTest;
@Category(UnitTest.class)
diff --git
a/geode-core/src/test/java/org/apache/geode/cache/query/BaseLineAndCompareQueryPerfJUnitTest.java
b/geode-core/src/test/java/org/apache/geode/cache/query/BaseLineAndCompareQueryPerfJUnitTest.java
index 53ace70..1787e97 100755
---
a/geode-core/src/test/java/org/apache/geode/cache/query/BaseLineAndCompareQueryPerfJUnitTest.java
+++
b/geode-core/src/test/java/org/apache/geode/cache/query/BaseLineAndCompareQueryPerfJUnitTest.java
@@ -362,7 +362,8 @@ public class BaseLineAndCompareQueryPerfJUnitTest {
* Indices share the following percentages: a. countryName: 20% objects b.
stateName: 33.33%
* objects c. districtName: 20% objects d. cityName: 50% objects e.
villageName: No index
*/
- // queryService.createIndex("villageName", IndexType.FUNCTIONAL, "v.name",
"/Countries c, c.states s,
+ // queryService.createIndex("villageName", IndexType.FUNCTIONAL, "v.name",
"/Countries c,
+ // c.states s,
// s.districts d, d.cities ct, d.villages v");
qs.createIndex("cityName", IndexType.FUNCTIONAL, "ct.name",
"/Countries c, c.states s, s.districts d, d.cities ct, d.villages
v");//
diff --git
a/geode-core/src/test/java/org/apache/geode/cache/query/PdxStringQueryJUnitTest.java
b/geode-core/src/test/java/org/apache/geode/cache/query/PdxStringQueryJUnitTest.java
index 9da499b..e0df096 100644
---
a/geode-core/src/test/java/org/apache/geode/cache/query/PdxStringQueryJUnitTest.java
+++
b/geode-core/src/test/java/org/apache/geode/cache/query/PdxStringQueryJUnitTest.java
@@ -135,8 +135,8 @@ public class PdxStringQueryJUnitTest {
@Test
public void testQueriesWithRangeIndex() throws Exception {
- Index index = queryService
- .createIndex("index2", "p.secId", "/exampleRegion p,
p.positions.values");
+ Index index =
+ queryService.createIndex("index2", "p.secId", "/exampleRegion p,
p.positions.values");
assertTrue(index instanceof RangeIndex);
PdxInstanceFactory pf = PdxInstanceFactoryImpl.newCreator("Portfolio",
false, this.cache);
pf.writeInt("ID", 111);
@@ -184,8 +184,8 @@ public class PdxStringQueryJUnitTest {
@Test
public void testQueriesWithRangeIndexWithREUpdateInProgress() throws
Exception {
- Index index = queryService
- .createIndex("index2", "p.secId", "/exampleRegion p,
p.positions.values");
+ Index index =
+ queryService.createIndex("index2", "p.secId", "/exampleRegion p,
p.positions.values");
assertTrue(index instanceof RangeIndex);
PdxInstanceFactory pf = PdxInstanceFactoryImpl.newCreator("Portfolio",
false, this.cache);
pf.writeInt("ID", 111);
@@ -602,8 +602,8 @@ public class PdxStringQueryJUnitTest {
query = new String[] {"select secId from /exampleRegion where secId > $1
and secId < $2",
"select p.secId from /exampleRegion p, p.positions.values v where
p.secId > $1 and p.secId < $2",
"select secId from /exampleRegion where secId > $1 and secId < $2"};
- res = (SelectResults) queryService
- .newQuery(query[indexType]).execute(new Object[] {"IBM", "YHOO"});
+ res = (SelectResults) queryService.newQuery(query[indexType])
+ .execute(new Object[] {"IBM", "YHOO"});
assertEquals(1, res.size());
iter = res.iterator();
secIdsList.clear();
diff --git
a/geode-core/src/test/java/org/apache/geode/cache/query/dunit/PdxStringQueryDUnitTest.java
b/geode-core/src/test/java/org/apache/geode/cache/query/dunit/PdxStringQueryDUnitTest.java
index 67af2a3..2a4af4f 100644
---
a/geode-core/src/test/java/org/apache/geode/cache/query/dunit/PdxStringQueryDUnitTest.java
+++
b/geode-core/src/test/java/org/apache/geode/cache/query/dunit/PdxStringQueryDUnitTest.java
@@ -81,9 +81,9 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
private static int bridgeServerPort;
private static final int orderByQueryIndex = 11;
- private static final int[] groupByQueryIndex = new int[]{7, 8, 9, 10};
+ private static final int[] groupByQueryIndex = new int[] {7, 8, 9, 10};
- private final String[] queryString = new String[]{
+ private final String[] queryString = new String[] {
"SELECT pos.secId FROM " + regName + " p, p.positions.values pos WHERE
pos.secId LIKE '%L'",
// 0
"SELECT pos.secId FROM " + regName + " p, p.positions.values pos where
pos.secId = 'IBM'",
@@ -112,7 +112,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
+ " p, p.positions.values pos WHERE p.ID > 1 order by pos.secId
limit 5",// 12
};
- private final String[] queryString2 = new String[]{
+ private final String[] queryString2 = new String[] {
"SELECT pos.secIdIndexed FROM " + regName
+ " p, p.positions.values pos WHERE pos.secIdIndexed LIKE '%L'", // 0
"SELECT pos.secIdIndexed FROM " + regName
@@ -204,7 +204,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
// Create client pool.
final String poolName = "testClientServerQueryPool";
- createPool(client, poolName, new String[]{host0}, new int[]{port0, port1,
port2}, true);
+ createPool(client, poolName, new String[] {host0}, new int[] {port0,
port1, port2}, true);
// Create client region and put PortfolioPdx objects (PdxInstances)
client.invoke(new CacheSerializableRunnable("Create client") {
@@ -246,8 +246,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][0] = (SelectResults) query.execute();
resWithoutIndexRemote[i] = rs[0][0];
LogWriterUtils.getLogWriter().info("RR remote indexType: no index
size of resultset: "
- + rs[0][0].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][0].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][0].asList(), queryString[i]);
LogWriterUtils.getLogWriter()
@@ -257,8 +256,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
resWithoutIndexLocal[i] = rs[0][1];
LogWriterUtils.getLogWriter()
.info("RR client local indexType:no index size of resultset:
" + rs[0][1].size()
- + " for query: " + queryString[i]);
- ;
+ + " for query: " + queryString[i]);;
checkForPdxString(rs[0][1].asList(), queryString[i]);
} catch (Exception e) {
Assert.fail("Failed executing " + queryString[i], e);
@@ -270,8 +268,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
Query query = remoteQueryService.newQuery(queryString2[i]);
resWithIndexRemote[i] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter().info("RR remote region2 size of
resultset: "
- + resWithIndexRemote[i].size() + " for query: " +
queryString2[i]);
- ;
+ + resWithIndexRemote[i].size() + " for query: " +
queryString2[i]);;
checkForPdxString(resWithIndexRemote[i].asList(), queryString2[i]);
// to compare local query results with and without index
@@ -280,8 +277,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
query = localQueryService.newQuery(queryString2[i]);
resWithIndexLocal[i] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter().info("RR local region2 size of
resultset: "
- + resWithIndexLocal[i].size() + " for query: " +
queryString2[i]);
- ;
+ + resWithIndexLocal[i].size() + " for query: " +
queryString2[i]);;
checkForPdxString(resWithIndexLocal[i].asList(), queryString2[i]);
} catch (Exception e) {
Assert.fail("Failed executing " + queryString2[i], e);
@@ -484,7 +480,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
// Create client pool.
final String poolName = "testClientServerQueryPool";
- createPool(client, poolName, new String[]{host0}, new int[]{port0, port1,
port2}, true);
+ createPool(client, poolName, new String[] {host0}, new int[] {port0,
port1, port2}, true);
// Create client region and put PortfolioPdx objects (PdxInstances)
client.invoke(new CacheSerializableRunnable("Create client") {
@@ -540,8 +536,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][0] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("RR remote indexType: CompactRange size of resultset: "
+ rs[0][0].size()
- + " for query: " + queryString[i]);
- ;
+ + " for query: " + queryString[i]);;
checkForPdxString(rs[0][0].asList(), queryString[i]);
LogWriterUtils.getLogWriter()
@@ -550,8 +545,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][1] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("RR client local indexType: CompactRange size of
resultset: "
- + rs[0][1].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][1].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][1].asList(), queryString[i]);
if (i < orderByQueryIndex) {
@@ -716,7 +710,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
// Create client pool.
final String poolName = "testClientServerQueryPool";
- createPool(client, poolName, new String[]{host0}, new int[]{port0, port1,
port2}, true);
+ createPool(client, poolName, new String[] {host0}, new int[] {port0,
port1, port2}, true);
// Create client region and put PortfolioPdx objects (PdxInstances)
client.invoke(new CacheSerializableRunnable("Create client") {
@@ -767,8 +761,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
Query query = remoteQueryService.newQuery(queryString[i]);
rs[0][0] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter().info("RR remote indexType: Range
size of resultset: "
- + rs[0][0].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][0].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][0].asList(), queryString[i]);
LogWriterUtils.getLogWriter()
@@ -777,8 +770,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][1] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("RR client local indexType: Range size of resultset: "
+ rs[0][1].size()
- + " for query: " + queryString[i]);
- ;
+ + " for query: " + queryString[i]);;
checkForPdxString(rs[0][1].asList(), queryString[i]);
if (i < orderByQueryIndex) {
@@ -949,7 +941,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
// Create client pool.
final String poolName = "testClientServerQueryPool";
- createPool(client, poolName, new String[]{host0}, new int[]{port0, port1,
port2}, true);
+ createPool(client, poolName, new String[] {host0}, new int[] {port0,
port1, port2}, true);
// Create client region and put PortfolioPdx objects (PdxInstances)
client.invoke(new CacheSerializableRunnable("Create client") {
@@ -991,8 +983,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][0] = (SelectResults) query.execute();
resWithoutIndexRemote[i] = rs[0][0];
LogWriterUtils.getLogWriter().info("RR remote no index size of
resultset: "
- + rs[0][0].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][0].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][0].asList(), queryString[i]);
LogWriterUtils.getLogWriter()
@@ -1002,8 +993,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
resWithoutIndexLocal[i] = rs[0][1];
LogWriterUtils.getLogWriter()
.info("isPR: " + isPr + " client local indexType:no index
size of resultset: "
- + rs[0][1].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][1].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][1].asList(), queryString[i]);
} catch (Exception e) {
Assert.fail("Failed executing " + queryString[i], e);
@@ -1016,8 +1006,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
resWithIndexRemote[i] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("isPR: " + isPr + " remote region2 size of resultset: "
- + resWithIndexRemote[i].size() + " for query: " +
queryString2[i]);
- ;
+ + resWithIndexRemote[i].size() + " for query: " +
queryString2[i]);;
checkForPdxString(resWithIndexRemote[i].asList(), queryString2[i]);
// to compare local query results with and without index
@@ -1027,8 +1016,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
resWithIndexLocal[i] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("isPR: " + isPr + " local region2 size of resultset: "
- + resWithIndexLocal[i].size() + " for query: " +
queryString2[i]);
- ;
+ + resWithIndexLocal[i].size() + " for query: " +
queryString2[i]);;
checkForPdxString(resWithIndexLocal[i].asList(), queryString2[i]);
} catch (Exception e) {
Assert.fail("Failed executing " + queryString2[i], e);
@@ -1238,7 +1226,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
// Create client pool.
final String poolName = "testClientServerQueryPool";
- createPool(client, poolName, new String[]{host0}, new int[]{port0, port1,
port2}, true);
+ createPool(client, poolName, new String[] {host0}, new int[] {port0,
port1, port2}, true);
// Create client region and put PortfolioPdx objects (PdxInstances)
client.invoke(new CacheSerializableRunnable("Create client") {
@@ -1301,8 +1289,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][0] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("RR remote indexType:CompactRange size of resultset: " +
rs[0][0].size()
- + " for query: " + queryString[i]);
- ;
+ + " for query: " + queryString[i]);;
checkForPdxString(rs[0][0].asList(), queryString[i]);
LogWriterUtils.getLogWriter()
@@ -1311,8 +1298,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][1] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("isPR: " + isPr + " client local indexType:CompactRange
size of resultset: "
- + rs[0][1].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][1].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][1].asList(), queryString[i]);
if (i < orderByQueryIndex) {
@@ -1485,7 +1471,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
// Create client pool.
final String poolName = "testClientServerQueryPool";
- createPool(client, poolName, new String[]{host0}, new int[]{port0, port1,
port2}, true);
+ createPool(client, poolName, new String[] {host0}, new int[] {port0,
port1, port2}, true);
// Create client region and put PortfolioPdx objects (PdxInstances)
client.invoke(new CacheSerializableRunnable("Create client") {
@@ -1545,8 +1531,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
Query query = remoteQueryService.newQuery(queryString[i]);
rs[0][0] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter().info("RR remote indexType: Range
size of resultset: "
- + rs[0][0].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][0].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][0].asList(), queryString[i]);
LogWriterUtils.getLogWriter()
@@ -1555,8 +1540,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
rs[0][1] = (SelectResults) query.execute();
LogWriterUtils.getLogWriter()
.info("isPR: " + isPr + " client local indexType: Range size
of resultset: "
- + rs[0][1].size() + " for query: " + queryString[i]);
- ;
+ + rs[0][1].size() + " for query: " + queryString[i]);;
checkForPdxString(rs[0][1].asList(), queryString[i]);
if (i < orderByQueryIndex) {
@@ -1732,7 +1716,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
// Create client pool.
final String poolName = "testClientServerQueryPool";
- createPool(client, poolName, new String[]{host0}, new int[]{port0, port1,
port2}, true);
+ createPool(client, poolName, new String[] {host0}, new int[] {port0,
port1, port2}, true);
// Create client region and put PortfolioPdx objects (PdxInstances)
client.invoke(new CacheSerializableRunnable("Create client") {
@@ -1809,8 +1793,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
Query query = remoteQueryService.newQuery(qs[i]);
SelectResults res = (SelectResults) query.execute();
LogWriterUtils.getLogWriter().info("PR NULL Pdxstring test size of
resultset: "
- + res.size() + " for query: " + qs[i]);
- ;
+ + res.size() + " for query: " + qs[i]);;
if (i == 0) {
for (Object o : res) {
if (o != null) {
@@ -1890,8 +1873,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
Iterator itert1 = null;
Iterator itert2 = null;
ObjectType type1, type2;
- outer:
- for (int j = 0; j < r.length; j++) {
+ outer: for (int j = 0; j < r.length; j++) {
CollectionType collType1 = r[j][0].getCollectionType();
CollectionType collType2 = r[j][1].getCollectionType();
type1 = collType1.getElementType();
@@ -2024,8 +2006,7 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
cache.getPdxRegistry().overridePdxReadSerialized(true);
try {
for (int i = 0; i < qs.length; i++) {
- SelectResults sr =
- (SelectResults)
getCache().getQueryService().newQuery(qs[i]).execute();
+ SelectResults sr = (SelectResults)
getCache().getQueryService().newQuery(qs[i]).execute();
assertEquals("Did not get expected result from query: " + qs[i] + "
", 2, sr.size());
}
} finally {
@@ -2101,21 +2082,21 @@ public class PdxStringQueryDUnitTest extends
JUnit4CacheTestCase {
}
public void createPool(VM vm, String poolName, String server, int port,
- boolean subscriptionEnabled) {
- createPool(vm, poolName, new String[]{server}, new int[]{port},
subscriptionEnabled);
+ boolean subscriptionEnabled) {
+ createPool(vm, poolName, new String[] {server}, new int[] {port},
subscriptionEnabled);
}
public void createPool(VM vm, String poolName, String server, int port) {
- createPool(vm, poolName, new String[]{server}, new int[]{port}, false);
+ createPool(vm, poolName, new String[] {server}, new int[] {port}, false);
}
public void createPool(VM vm, final String poolName, final String[] servers,
final int[] ports,
- final boolean subscriptionEnabled) {
+ final boolean subscriptionEnabled) {
createPool(vm, poolName, servers, ports, subscriptionEnabled, 0);
}
public void createPool(VM vm, final String poolName, final String[] servers,
final int[] ports,
- final boolean subscriptionEnabled, final int
redundancy) {
+ final boolean subscriptionEnabled, final int redundancy) {
vm.invoke(new CacheSerializableRunnable("createPool :" + poolName) {
public void run2() throws CacheException {
// Create Cache.
diff --git
a/geode-core/src/test/java/org/apache/geode/internal/PdxDeleteFieldJUnitTest.java
b/geode-core/src/test/java/org/apache/geode/internal/PdxDeleteFieldJUnitTest.java
index aa5d013..33f4c09 100644
---
a/geode-core/src/test/java/org/apache/geode/internal/PdxDeleteFieldJUnitTest.java
+++
b/geode-core/src/test/java/org/apache/geode/internal/PdxDeleteFieldJUnitTest.java
@@ -24,7 +24,6 @@ import java.util.Collection;
import java.util.Properties;
import org.apache.commons.io.FileUtils;
-import org.apache.geode.internal.cache.InternalCache;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -37,6 +36,7 @@ import org.apache.geode.cache.RegionShortcut;
import org.apache.geode.cache.query.internal.DefaultQuery;
import org.apache.geode.internal.cache.DiskStoreImpl;
import org.apache.geode.internal.cache.GemFireCacheImpl;
+import org.apache.geode.internal.cache.InternalCache;
import org.apache.geode.internal.util.BlobHelper;
import org.apache.geode.pdx.PdxInstance;
import org.apache.geode.pdx.PdxInstanceFactory;
diff --git
a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/IndexRepositoryFactory.java
b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/IndexRepositoryFactory.java
index f61135b..fae8963 100644
---
a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/IndexRepositoryFactory.java
+++
b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/IndexRepositoryFactory.java
@@ -20,7 +20,6 @@ import java.util.Iterator;
import java.util.Map;
import java.util.Set;
-import org.apache.geode.internal.cache.InternalCache;
import org.apache.logging.log4j.Logger;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
@@ -37,6 +36,7 @@ import org.apache.geode.cache.query.internal.DefaultQuery;
import org.apache.geode.distributed.DistributedLockService;
import org.apache.geode.internal.cache.BucketRegion;
import org.apache.geode.internal.cache.EntrySnapshot;
+import org.apache.geode.internal.cache.InternalCache;
import org.apache.geode.internal.cache.PartitionRegionConfig;
import org.apache.geode.internal.cache.PartitionedRegion;
import org.apache.geode.internal.cache.PartitionedRegionHelper;
diff --git
a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/LuceneEventListenerJUnitTest.java
b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/LuceneEventListenerJUnitTest.java
index 6076d59..538a6e2 100644
---
a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/LuceneEventListenerJUnitTest.java
+++
b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/LuceneEventListenerJUnitTest.java
@@ -27,17 +27,12 @@ import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-import org.apache.geode.InternalGemFireError;
-import org.apache.geode.cache.Region;
-import org.apache.geode.cache.asyncqueue.AsyncEvent;
-import org.apache.geode.cache.lucene.internal.repository.IndexRepository;
-import org.apache.geode.cache.lucene.internal.repository.RepositoryManager;
-import org.apache.geode.internal.cache.BucketNotFoundException;
-import org.apache.geode.internal.cache.EntrySnapshot;
-import org.apache.geode.internal.cache.InternalCache;
-import org.apache.geode.internal.logging.LogService;
-import org.apache.geode.test.fake.Fakes;
-import org.apache.geode.test.junit.categories.UnitTest;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.atomic.AtomicReference;
+
import org.apache.logging.log4j.Logger;
import org.junit.After;
import org.junit.Before;
@@ -50,11 +45,17 @@ import
org.powermock.core.classloader.annotations.PowerMockIgnore;
import org.powermock.core.classloader.annotations.PrepareForTest;
import org.powermock.modules.junit4.PowerMockRunner;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.concurrent.atomic.AtomicReference;
+import org.apache.geode.InternalGemFireError;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.asyncqueue.AsyncEvent;
+import org.apache.geode.cache.lucene.internal.repository.IndexRepository;
+import org.apache.geode.cache.lucene.internal.repository.RepositoryManager;
+import org.apache.geode.internal.cache.BucketNotFoundException;
+import org.apache.geode.internal.cache.EntrySnapshot;
+import org.apache.geode.internal.cache.InternalCache;
+import org.apache.geode.internal.logging.LogService;
+import org.apache.geode.test.fake.Fakes;
+import org.apache.geode.test.junit.categories.UnitTest;
/**
* Unit test that async event listener dispatched the events to the
appropriate repository.
--
To stop receiving notification emails like this one, please contact
[email protected].
