Keep exception’s caused by when re-throwing

Author: bwaldvogel

core/src/main/java/de/bwaldvogel/mongo/backend/AbstractMongoCollection.java

@@ -414,8 +414,8 @@ public Document findAndModify(Document query) {
                     oldDocument = updateDocument(document, updateQuery, arrayFilters, matchPos);
                 } catch (MongoServerError e) {
                     if (e.shouldPrefixCommandContext()) {
-                        String prefix = "Plan executor error during findAndModify :: caused by :: ";
-                        throw new MongoServerError(e.getCode(), e.getCodeName(), prefix + e.getMessageWithoutErrorCode());
+                        throw new FindAndModifyPlanExecutorError(e);
+
                     } else {
                         throw e;
                     }
@@ -457,6 +457,17 @@ public Document findAndModify(Document query) {
         return result;
     }
 
+    private static class FindAndModifyPlanExecutorError extends MongoServerError {
+
+        private static final long serialVersionUID = 1L;
+
+        private static final String PREFIX = "Plan executor error during findAndModify :: caused by :: ";
+
+        private FindAndModifyPlanExecutorError(MongoServerError cause) {
+            super(cause.getCode(), cause.getCodeName(), PREFIX + cause.getMessageWithoutErrorCode(), cause);
+        }
+    }
+
     @Override
     public QueryResult handleQuery(QueryParameters queryParameters) {
         final Document query;

core/src/main/java/de/bwaldvogel/mongo/backend/aggregation/Aggregation.java

@@ -272,7 +272,7 @@ public boolean isModifying() {
         return stages.stream().anyMatch(AggregationStage::isModifying);
     }
 
-    public static class PlanExecutorError extends MongoServerError {
+    private static class PlanExecutorError extends MongoServerError {
 
         private static final long serialVersionUID = 1L;