File tree 1 file changed +6
-2
lines changed
src/main/java/com/amazon/sqs/javamessaging
1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -196,9 +196,13 @@ public CompletableFuture<ReceiveMessageResponse> receiveMessage(ReceiveMessageRe
196
196
197
197
return super .receiveMessage (receiveMessageRequest )
198
198
.thenCompose (receiveMessageResponse -> {
199
- ReceiveMessageResponse .Builder receiveMessageResponseBuilder = receiveMessageResponse .toBuilder ();
200
-
201
199
List <Message > messages = receiveMessageResponse .messages ();
200
+
201
+ // Check for no messages. If so, no need to process further.
202
+ if (messages .isEmpty ()) {
203
+ return CompletableFuture .completedFuture (messages );
204
+ }
205
+
202
206
List <CompletableFuture <Message >> modifiedMessageFutures = new ArrayList <>(messages .size ());
203
207
for (Message message : messages ) {
204
208
Message .Builder messageBuilder = message .toBuilder ();
You can’t perform that action at this time.
0 commit comments