camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [1/6] camel git commit: Fixed ChronicleEngineProducer After upgrade
Date Tue, 22 Nov 2016 09:18:40 GMT
Repository: camel
Updated Branches:
  refs/heads/master fc447e8ba -> 603dfb48a


Fixed ChronicleEngineProducer After upgrade


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/603dfb48
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/603dfb48
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/603dfb48

Branch: refs/heads/master
Commit: 603dfb48a6f0aa5a091f82c40e585a5d2b46eda8
Parents: 3c39c35
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Tue Nov 22 10:18:01 2016 +0100
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Tue Nov 22 10:18:22 2016 +0100

----------------------------------------------------------------------
 .../camel/component/chronicle/engine/ChronicleEngineProducer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/603dfb48/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
index 9d41799..c8513d4 100644
--- a/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
+++ b/components/camel-chronicle/src/main/java/org/apache/camel/component/chronicle/engine/ChronicleEngineProducer.java
@@ -147,7 +147,7 @@ public class ChronicleEngineProducer extends HeaderSelectorProducer {
                     message.getHeader(ChronicleEngineConstants.DEFAULT_VALUE))
             );
         } else {
-            QueueView.Excerpt<Object, Object> excerpt = queueView.get().get(index.longValue());
+            QueueView.Excerpt<Object, Object> excerpt = queueView.get().getExcerpt(index.longValue());
 
             message.setHeader(ChronicleEngineConstants.PATH, excerpt.topic());
             message.setBody(excerpt.message());


Mime
View raw message