Skip to content

CAMEL-24307: camel-aws2-rekognition - throw when pojoRequest=true and the body is the wrong type #25243

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
oscerd merged 1 commit into from
Jul 30, 2026
Merged

CAMEL-24307: camel-aws2-rekognition - throw when pojoRequest=true and the body is the wrong type #25243

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions components/camel-aws/camel-aws2-rekognition/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,11 @@
<version>${project.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
<scope>test</scope>
</dependency>
</dependencies>

</project>
81 changes: 81 additions & 0 deletions ...ition/src/main/java/org/apache/camel/component/aws2/rekognition/Rekognition2Producer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -188,6 +188,9 @@ private void associateFaces(RekognitionClient rekognitionClient, Exchange exchan
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"associateFaces operation requires AssociateFacesRequest in POJO mode");
}
} else {
AssociateFacesRequest.Builder builder = AssociateFacesRequest.builder();
Expand Down Expand Up @@ -237,6 +240,9 @@ private void compareFaces(RekognitionClient rekognitionClient, Exchange exchange
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"compareFaces operation requires CompareFacesRequest in POJO mode");
}
} else {
CompareFacesRequest.Builder builder = CompareFacesRequest.builder();
Expand Down Expand Up @@ -281,6 +287,9 @@ private void createCollection(RekognitionClient rekognitionClient, Exchange exch
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"createCollection operation requires CreateCollectionRequest in POJO mode");
}
} else {
CreateCollectionRequest.Builder builder = CreateCollectionRequest.builder();
Expand Down Expand Up @@ -313,6 +322,9 @@ private void createUser(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"createUser operation requires CreateUserRequest in POJO mode");
}
} else {
CreateUserRequest.Builder builder = CreateUserRequest.builder();
Expand Down Expand Up @@ -354,6 +366,9 @@ private void deleteCollection(RekognitionClient rekognitionClient, Exchange exch
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"deleteCollection operation requires DeleteCollectionRequest in POJO mode");
}
} else {
DeleteCollectionRequest.Builder builder = DeleteCollectionRequest.builder();
Expand Down Expand Up @@ -386,6 +401,9 @@ private void deleteFaces(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"deleteFaces operation requires DeleteFacesRequest in POJO mode");
}
} else {
DeleteFacesRequest.Builder builder = DeleteFacesRequest.builder();
Expand Down Expand Up @@ -422,6 +440,9 @@ private void deleteUser(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"deleteUser operation requires DeleteUserRequest in POJO mode");
}
} else {
DeleteUserRequest.Builder builder = DeleteUserRequest.builder();
Expand Down Expand Up @@ -463,6 +484,9 @@ private void describeCollection(RekognitionClient rekognitionClient, Exchange ex
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"describeCollection operation requires DescribeCollectionRequest in POJO mode");
}
} else {
DescribeCollectionRequest.Builder builder = DescribeCollectionRequest.builder();
Expand Down Expand Up @@ -495,6 +519,9 @@ private void detectFaces(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"detectFaces operation requires DetectFacesRequest in POJO mode");
}
} else {
DetectFacesRequest.Builder builder = DetectFacesRequest.builder();
Expand Down Expand Up @@ -531,6 +558,9 @@ private void detectLabels(RekognitionClient rekognitionClient, Exchange exchange
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"detectLabels operation requires DetectLabelsRequest in POJO mode");
}
} else {
DetectLabelsRequest.Builder builder = DetectLabelsRequest.builder();
Expand Down Expand Up @@ -581,6 +611,9 @@ private void detectModerationLabels(RekognitionClient rekognitionClient, Exchang
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"detectModerationLabels operation requires DetectModerationLabelsRequest in POJO mode");
}
} else {
DetectModerationLabelsRequest.Builder builder = DetectModerationLabelsRequest.builder();
Expand Down Expand Up @@ -628,6 +661,9 @@ private void detectProtectiveEquipment(RekognitionClient rekognitionClient, Exch
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"detectProtectiveEquipment operation requires DetectProtectiveEquipmentRequest in POJO mode");
}
} else {
DetectProtectiveEquipmentRequest.Builder builder = DetectProtectiveEquipmentRequest.builder();
Expand Down Expand Up @@ -667,6 +703,9 @@ private void detectText(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"detectText operation requires DetectTextRequest in POJO mode");
}
} else {
DetectTextRequest.Builder builder = DetectTextRequest.builder();
Expand Down Expand Up @@ -704,6 +743,9 @@ private void disassociateFaces(RekognitionClient rekognitionClient, Exchange exc
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"disassociateFaces operation requires DisassociateFacesRequest in POJO mode");
}
} else {
DisassociateFacesRequest.Builder builder = DisassociateFacesRequest.builder();
Expand Down Expand Up @@ -749,6 +791,9 @@ private void getCelebrityInfo(RekognitionClient rekognitionClient, Exchange exch
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"getCelebrityInfo operation requires GetCelebrityInfoRequest in POJO mode");
}
} else {
GetCelebrityInfoRequest.Builder builder = GetCelebrityInfoRequest.builder();
Expand Down Expand Up @@ -781,6 +826,9 @@ private void getMediaAnalysisJob(RekognitionClient rekognitionClient, Exchange e
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"getMediaAnalysisJob operation requires GetMediaAnalysisJobRequest in POJO mode");
}
} else {
GetMediaAnalysisJobRequest.Builder builder = GetMediaAnalysisJobRequest.builder();
Expand Down Expand Up @@ -813,6 +861,9 @@ private void indexFaces(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"indexFaces operation requires IndexFacesRequest in POJO mode");
}
} else {
IndexFacesRequest.Builder builder = IndexFacesRequest.builder();
Expand Down Expand Up @@ -866,6 +917,9 @@ private void listCollections(RekognitionClient rekognitionClient, Exchange excha
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"listCollections operation requires ListCollectionsRequest in POJO mode");
}
} else {
ListCollectionsRequest.Builder builder = ListCollectionsRequest.builder();
Expand Down Expand Up @@ -902,6 +956,9 @@ private void listMediaAnalysisJobs(RekognitionClient rekognitionClient, Exchange
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"listMediaAnalysisJobs operation requires ListMediaAnalysisJobsRequest in POJO mode");
}
} else {
ListMediaAnalysisJobsRequest.Builder builder = ListMediaAnalysisJobsRequest.builder();
Expand Down Expand Up @@ -938,6 +995,9 @@ private void listFaces(RekognitionClient rekognitionClient, Exchange exchange) t
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"listFaces operation requires ListFacesRequest in POJO mode");
}
} else {
ListFacesRequest.Builder builder = ListFacesRequest.builder();
Expand Down Expand Up @@ -986,6 +1046,9 @@ private void listUsers(RekognitionClient rekognitionClient, Exchange exchange) t
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"listUsers operation requires ListUsersRequest in POJO mode");
}
} else {
ListUsersRequest.Builder builder = ListUsersRequest.builder();
Expand Down Expand Up @@ -1026,6 +1089,9 @@ private void recognizeCelebrities(RekognitionClient rekognitionClient, Exchange
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"recognizeCelebrities operation requires RecognizeCelebritiesRequest in POJO mode");
}
} else {
RecognizeCelebritiesRequest.Builder builder = RecognizeCelebritiesRequest.builder();
Expand Down Expand Up @@ -1058,6 +1124,9 @@ private void searchFaces(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"searchFaces operation requires SearchFacesRequest in POJO mode");
}
} else {
SearchFacesRequest.Builder builder = SearchFacesRequest.builder();
Expand Down Expand Up @@ -1102,6 +1171,9 @@ private void searchFacesByImage(RekognitionClient rekognitionClient, Exchange ex
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"searchFacesByImage operation requires SearchFacesByImageRequest in POJO mode");
}
} else {
SearchFacesByImageRequest.Builder builder = SearchFacesByImageRequest.builder();
Expand Down Expand Up @@ -1150,6 +1222,9 @@ private void searchUsers(RekognitionClient rekognitionClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"searchUsers operation requires SearchUsersRequest in POJO mode");
}
} else {
SearchUsersRequest.Builder builder = SearchUsersRequest.builder();
Expand Down Expand Up @@ -1198,6 +1273,9 @@ private void searchUsersByImage(RekognitionClient rekognitionClient, Exchange ex
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"searchUsersByImage operation requires SearchUsersByImageRequest in POJO mode");
}
} else {
SearchUsersByImageRequest.Builder builder = SearchUsersByImageRequest.builder();
Expand Down Expand Up @@ -1246,6 +1324,9 @@ private void startMediaAnalysisJob(RekognitionClient rekognitionClient, Exchange
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"startMediaAnalysisJob operation requires StartMediaAnalysisJobRequest in POJO mode");
}
} else {
StartMediaAnalysisJobRequest.Builder builder = StartMediaAnalysisJobRequest.builder();
Expand Down
Loading