This is an automated email from the ASF dual-hosted git repository.
dschneider pushed a commit to branch feature/GEODE-3781
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-3781 by this
push:
new 72fa66f spotless
72fa66f is described below
commit 72fa66f25748e3bffee5e2bc5e1df4a59673c162
Author: Darrel Schneider <[email protected]>
AuthorDate: Mon Oct 30 11:07:31 2017 -0700
spotless
---
.../main/java/org/apache/geode/connectors/jdbc/JDBCAsyncWriter.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
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 5ddeda7..cad774d 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
@@ -58,7 +58,7 @@ public class JDBCAsyncWriter implements AsyncEventListener {
PdxInstance value = (PdxInstance) event.getDeserializedValue();
logger.info("AsyncEventListener event : " + event);
this.manager.write(event.getRegion(), event.getOperation(),
event.getKey(), value);
-
+
changeSuccessfulEvents(1);
} catch (RuntimeException ex) {
// TODO improve the following logging
@@ -80,12 +80,15 @@ public class JDBCAsyncWriter implements AsyncEventListener {
private synchronized void changeTotalEvents(long delta) {
this.totalEvents += delta;
}
+
public synchronized long getTotalEvents() {
return this.totalEvents;
}
+
private synchronized void changeSuccessfulEvents(long delta) {
this.successfulEvents += delta;
}
+
public synchronized long getSuccessfulEvents() {
return this.successfulEvents;
}
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
