Added onFailure block for S3 operations

- Failures were not getting caught in the compose
datakaveri · May 22, 2024 · 4e03817 · 4e03817
1 parent 85fbb56
commit 4e03817
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/main/java/ogc/rs/common/DataFromS3.java b/src/main/java/ogc/rs/common/DataFromS3.java
@@ -57,8 +57,15 @@ public Future<HttpClientResponse> getDataFromS3(HttpMethod httpMethod) {
             response.fail(new OgcException(500, "Internal Server Error", "Internal Server Error"));
             return response.future();
           }
-        });
-
+        }).onFailure( 
+            handler -> { 
+              LOGGER.error("Something went wrong when interacting with S3 - {}. Method {}, URL {} ",
+                  handler.getMessage(), httpMethod, url.toString());
+
+              response.fail( 
+                  new OgcException(500, "Internal Server Error", "Internal Server Error")); 
+            });
+
     return response.future();
   }