Fixes SQS empty batch delete error (#168)

openzipkin · May 11, 2020 · ea49a83 · ea49a83
1 parent 9369686
commit ea49a83
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/collector-sqs/src/main/java/zipkin2/collector/sqs/SQSSpanProcessor.java b/collector-sqs/src/main/java/zipkin2/collector/sqs/SQSSpanProcessor.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2019 The OpenZipkin Authors
+ * Copyright 2016-2020 The OpenZipkin Authors
  *
  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
  * in compliance with the License. You may obtain a copy of the License at
@@ -136,7 +136,9 @@ public void onError(Throwable t) {
       }
     }
 
-    delete(toDelete);
+    if (!toDelete.isEmpty()) {
+      delete(toDelete);
+    }
   }
 
   private DeleteMessageBatchResult delete(List<DeleteMessageBatchRequestEntry> entries) {