You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/10/20 11:16:57 UTC
[camel] branch camel-2.19.x updated: CAMEL-11922: Persistent tail
tracking picks random tail tracker from mongoDB collection for component
MongoDB3
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-2.19.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.19.x by this push:
new 3ab7b58 CAMEL-11922: Persistent tail tracking picks random tail tracker from mongoDB collection for component MongoDB3
3ab7b58 is described below
commit 3ab7b580f6b0f2f966411cf636aacd447c271647
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 20 13:11:40 2017 +0200
CAMEL-11922: Persistent tail tracking picks random tail tracker from mongoDB collection for component MongoDB3
---
.../camel/component/mongodb3/MongoDbTailTrackingManager.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbTailTrackingManager.java b/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbTailTrackingManager.java
index 1c81d1e..4627f74 100644
--- a/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbTailTrackingManager.java
+++ b/components/camel-mongodb3/src/main/java/org/apache/camel/component/mongodb3/MongoDbTailTrackingManager.java
@@ -18,6 +18,8 @@ package org.apache.camel.component.mongodb3;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
+import com.mongodb.client.model.FindOneAndUpdateOptions;
+import com.mongodb.client.model.ReturnDocument;
import com.mongodb.client.model.Updates;
import org.bson.Document;
@@ -70,8 +72,9 @@ public class MongoDbTailTrackingManager {
}
Bson updateObj = Updates.set(config.field, lastVal);
- dbCol.updateOne(trackingObj, updateObj);
- trackingObj = dbCol.find().first();
+ FindOneAndUpdateOptions options = new FindOneAndUpdateOptions()
+ .returnDocument(ReturnDocument.AFTER);
+ trackingObj = dbCol.findOneAndUpdate(trackingObj, updateObj, options);
}
public synchronized Object recoverFromStore() {
--
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <co...@camel.apache.org>'].