You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ag...@apache.org on 2017/10/23 19:08:05 UTC
[geode] 02/02: whitespace cleanup
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 <ag...@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" <co...@geode.apache.org>.