open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Guard against null list from aws SQS lib (#9710) 

Co-authored-by: Trask Stalnaker <trask.stalnaker@gmail.com>
This commit is contained in:
jason plumb 2023-10-19 22:55:35 -07:00 committed by GitHub
parent 0fc1a99b82
commit 30e54364f2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
instrumentation/aws-lambda/aws-lambda-events-2.2/library/src/main/java/io/opentelemetry/instrumentation/awslambdaevents/v2_2/internal/AwsLambdaSqsInstrumenterFactory.java
View File

@ -10,6 +10,7 @@ import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
import io.opentelemetry.instrumentation.api.instrumenter.SpanKindExtractor;
import java.util.List;
/**
* This class is internal and is hence not for public use. Its APIs are unstable and can change at
@ -39,10 +40,11 @@ public final class AwsLambdaSqsInstrumenterFactory {
private static String spanName(SQSEvent event) {
String source = "multiple_sources";
if (!event.getRecords().isEmpty()) {
String messageSource = event.getRecords().get(0).getEventSource();
for (int i = 1; i < event.getRecords().size(); i++) {
SQSMessage message = event.getRecords().get(i);
List<SQSMessage> records = event.getRecords();
if (records != null && !records.isEmpty()) {
String messageSource = records.get(0).getEventSource();
for (int i = 1; i < records.size(); i++) {
SQSMessage message = records.get(i);
if (!message.getEventSource().equals(messageSource)) {
messageSource = null;
break;