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/master Commit: 00eb13965e2b31bc1c57e437ceac0a42f6610861 Parents: c08e02a Author: Dave Johnson <[email protected]> Authored: Thu Sep 22 07:47:44 2016 -0400 Committer: Dave Johnson <[email protected]> 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
