0003677: Failed to deserialize event error when monitor fires

JumpMind · Aug 16, 2018 · 5bcfa23 · 5bcfa23
1 parent 9653a35
commit 5bcfa23
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/model/AbstractBatch.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/model/AbstractBatch.java
@@ -411,7 +411,7 @@ public void setStatus(Status status) {
         this.status = status;
     }
 
-    public void setStatus(String status) {
+    public void setStatusFromString(String status) {
         try {
             this.status = Status.valueOf(status);
         } catch (IllegalArgumentException e) {

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
@@ -490,7 +490,7 @@ public IncomingBatch mapRow(Row rs) {
             batch.setBatchId(rs.getLong("batch_id"));
             batch.setNodeId(rs.getString("node_id"));
             batch.setChannelId(rs.getString("channel_id"));
-            batch.setStatus(rs.getString("status"));
+            batch.setStatusFromString(rs.getString("status"));
             batch.setRouterMillis(rs.getLong("router_millis"));
             batch.setNetworkMillis(rs.getLong("network_millis"));
             batch.setFilterMillis(rs.getLong("filter_millis"));

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
@@ -1087,7 +1087,7 @@ public OutgoingBatch mapRow(Row rs) {
             if (channel != null && (includeDisabledChannels || channel.isEnabled())) {
                 OutgoingBatch batch = new OutgoingBatch();
                 batch.setNodeId(rs.getString("node_id"));
-                batch.setStatus(rs.getString("status"));
+                batch.setStatusFromString(rs.getString("status"));
                 batch.setBatchId(rs.getLong("batch_id"));
                 if (!statusOnly) {
                     batch.setChannelId(channelId);