You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2016/09/30 21:18:52 UTC
[07/10] usergrid git commit: Make DatabaseQueueMessage serializable
because it is sent in Akka messages
Make DatabaseQueueMessage serializable because it is sent in Akka messages
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/00eb1396
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/00eb1396
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/00eb1396
Branch: refs/heads/usergrid-1318-queue
Commit: 00eb13965e2b31bc1c57e437ceac0a42f6610861
Parents: c08e02a
Author: Dave Johnson <sn...@apache.org>
Authored: Thu Sep 22 07:47:44 2016 -0400
Committer: Dave Johnson <sn...@apache.org>
Committed: Thu Sep 22 07:47:44 2016 -0400
----------------------------------------------------------------------
.../qakka/serialization/queuemessages/DatabaseQueueMessage.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/00eb1396/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessage.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessage.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessage.java
index dab47d5..89a3eeb 100644
--- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessage.java
+++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessage.java
@@ -19,10 +19,11 @@
package org.apache.usergrid.persistence.qakka.serialization.queuemessages;
+import java.io.Serializable;
import java.util.UUID;
-public class DatabaseQueueMessage {
+public class DatabaseQueueMessage implements Serializable {
public enum Type {
DEFAULT, INFLIGHT