Revision 52042
Added by Claudio Atzori almost 6 years ago
| MongoBulkWritesManager.java | ||
|---|---|---|
| 122 | 122 |
obj.put("id", recordProperties.get("id"));
|
| 123 | 123 |
obj.put("originalId", recordProperties.get("originalId"));
|
| 124 | 124 |
obj.put("body", record);
|
| 125 |
obj.put("timestamp", System.currentTimeMillis());
|
|
| 125 |
obj.put("timestamp", recordProperties.get("timestamp"));
|
|
| 126 | 126 |
if (indexFieldProperties != null) |
| 127 | 127 |
obj.putAll(indexFieldProperties); |
| 128 | 128 |
return obj; |
Also available in: Unified diff
use the same (hopefully) format for field timestamp, and the same value for each record involved in a transaction