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/212b3ce3 Tree: http://git-wip-us.apache.org/repos/asf/ode-jacob/tree/212b3ce3 Diff: http://git-wip-us.apache.org/repos/asf/ode-jacob/diff/212b3ce3 Branch: refs/heads/master Commit: 212b3ce36707ee85a47d35ed5f61303fffe68bb3 Parents: 61e0bb0 Author: Tammo van Lessen <[email protected]> Authored: Thu Aug 15 16:34:34 2013 +0200 Committer: Tammo van Lessen <[email protected]> Committed: Thu Aug 15 16:34:34 2013 +0200 ---------------------------------------------------------------------- .../apache/ode/jacob/soup/jackson/JacksonExecutionQueueImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode-jacob/blob/212b3ce3/src/main/java/org/apache/ode/jacob/soup/jackson/JacksonExecutionQueueImpl.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/ode/jacob/soup/jackson/JacksonExecutionQueueImpl.java b/src/main/java/org/apache/ode/jacob/soup/jackson/JacksonExecutionQueueImpl.java index 00076e9..73f700b 100644 --- a/src/main/java/org/apache/ode/jacob/soup/jackson/JacksonExecutionQueueImpl.java +++ b/src/main/java/org/apache/ode/jacob/soup/jackson/JacksonExecutionQueueImpl.java @@ -118,7 +118,7 @@ public class JacksonExecutionQueueImpl extends ExecutionQueueImpl { // skip } else { LOG.debug("GC Channel: {}", cframe); - i.remove(); + //i.remove(); } }
