Updated Branches: refs/heads/master 212b3ce36 -> 4556e9bc9
Messages now have an ID. Project: http://git-wip-us.apache.org/repos/asf/ode-jacob/repo Commit: http://git-wip-us.apache.org/repos/asf/ode-jacob/commit/0a14bc63 Tree: http://git-wip-us.apache.org/repos/asf/ode-jacob/tree/0a14bc63 Diff: http://git-wip-us.apache.org/repos/asf/ode-jacob/diff/0a14bc63 Branch: refs/heads/master Commit: 0a14bc63845877dee86a2867a70c9ad5df8f657e Parents: 212b3ce Author: Tammo van Lessen <[email protected]> Authored: Thu Aug 15 16:57:03 2013 +0200 Committer: Tammo van Lessen <[email protected]> Committed: Thu Aug 15 16:57:03 2013 +0200 ---------------------------------------------------------------------- src/main/java/org/apache/ode/jacob/Message.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode-jacob/blob/0a14bc63/src/main/java/org/apache/ode/jacob/Message.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/ode/jacob/Message.java b/src/main/java/org/apache/ode/jacob/Message.java index ccf2611..5d62135 100644 --- a/src/main/java/org/apache/ode/jacob/Message.java +++ b/src/main/java/org/apache/ode/jacob/Message.java @@ -21,6 +21,7 @@ package org.apache.ode.jacob; import java.io.Serializable; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.atomic.AtomicLong; /** @@ -31,6 +32,8 @@ import java.util.concurrent.ConcurrentHashMap; public class Message implements Serializable { private static final long serialVersionUID = -2118625760125445959L; + private static final AtomicLong idGen = new AtomicLong(); + private long id; private ChannelRef to; private ChannelRef replyTo; @@ -39,7 +42,7 @@ public class Message implements Serializable { private Object body; public Message() { - id = 0; // TODO: generate id + id = idGen.incrementAndGet(); // TODO: always allocating headers may not be a good idea // checking for non-null headers in the getters below is // not great either; should look into a better option later @@ -111,8 +114,7 @@ public class Message implements Serializable { public static Message copyFrom(Message message) { Message result = new Message(); - //XXX: generate id - result.setId(0); + result.setId(idGen.incrementAndGet()); result.setAction(message.getAction()); result.setBody(message.getBody());
