This is an automated email from the ASF dual-hosted git repository. agingade pushed a commit to branch feature/GEODE-3781 in repository https://gitbox.apache.org/repos/asf/geode.git
commit 6fe8b5213aa0ea02e23a12335a80be37bf11b740 Author: Anil <aging...@pivotal.io> AuthorDate: Mon Oct 23 12:07:04 2017 -0700 whitespace cleanup --- .../geode/connectors/jdbc/JDBCAsyncWriter.java | 2 +- .../jdbc/JDBCAsyncWriterIntegrationTest.java | 20 ++++++++++---------- 2 files changed, 11 insertions(+), 11 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 cc0b30d..af06539 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 @@ -22,7 +22,7 @@ import org.apache.geode.cache.asyncqueue.AsyncEventListener; /* * This class provides write behind cache semantics for a JDBC data source using AsyncEventListener. - * + * * @since Geode 1.4 */ public class JDBCAsyncWriter implements AsyncEventListener { diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JDBCAsyncWriterIntegrationTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JDBCAsyncWriterIntegrationTest.java index d135dfc..89101f6 100644 --- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JDBCAsyncWriterIntegrationTest.java +++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JDBCAsyncWriterIntegrationTest.java @@ -39,17 +39,17 @@ import org.awaitility.Awaitility; public class JDBCAsyncWriterIntegrationTest { private Cache cache; - + private Connection conn; - + private Statement stmt; JDBCAsyncWriter jdbcWriter; private String dbName="DerbyDB"; - + private String regionTableName = "employees"; - + @Before public void setup() throws Exception { try { @@ -87,7 +87,7 @@ public class JDBCAsyncWriterIntegrationTest { } stmt.execute("Drop table " + regionTableName); stmt.close(); - + if (conn != null) { conn.close(); } @@ -108,13 +108,13 @@ public class JDBCAsyncWriterIntegrationTest { @Test public void jdbcAsyncWriterCanWriteToDatabase() throws Exception { Region employees = createRegionWithJDBCAsyncWriter("employees"); - + employees.put("1", "Emp1"); employees.put("2", "Emp2"); validateTableRowCount(2); } - + private Region createRegionWithJDBCAsyncWriter(String regionName) { jdbcWriter = new JDBCAsyncWriter(); cache.createAsyncEventQueueFactory().setBatchSize(1) @@ -122,9 +122,9 @@ public class JDBCAsyncWriterIntegrationTest { RegionFactory rf = cache.createRegionFactory(RegionShortcut.REPLICATE); rf.addAsyncEventQueueId("jdbcAsyncQueue"); - return rf.create(regionName); + return rf.create(regionName); } - + private void validateTableRowCount(int expected) throws Exception { Awaitility.await().atMost(1, TimeUnit.SECONDS).until(() -> { int size = 0; @@ -140,5 +140,5 @@ public class JDBCAsyncWriterIntegrationTest { assertThat(size).isEqualTo(expected); }); } - + } -- To stop receiving notification emails like this one, please contact "commits@geode.apache.org" <commits@geode.apache.org>.