Skip to content

CAMEL-24316: camel-aws2-transcribe - throw when pojoRequest=true and the body is the wrong type #25250

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-24316: camel-aws2-transcribe - throw when pojoRequest=true and the body is the wrong type #25250

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
90 changes: 90 additions & 0 deletions ...nscribe/src/main/java/org/apache/camel/component/aws2/transcribe/Transcribe2Producer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -156,6 +156,9 @@ private void startTranscriptionJob(TranscribeClient transcribeClient, Exchange e
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"startTranscriptionJob operation requires StartTranscriptionJobRequest in POJO mode");
}
} else {
StartTranscriptionJobRequest.Builder builder = StartTranscriptionJobRequest.builder();
Expand Down Expand Up @@ -200,6 +203,9 @@ private void getTranscriptionJob(TranscribeClient transcribeClient, Exchange exc
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"getTranscriptionJob operation requires GetTranscriptionJobRequest in POJO mode");
}
} else {
GetTranscriptionJobRequest.Builder builder = GetTranscriptionJobRequest.builder();
Expand Down Expand Up @@ -232,6 +238,9 @@ private void listTranscriptionJobs(TranscribeClient transcribeClient, Exchange e
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"listTranscriptionJobs operation requires ListTranscriptionJobsRequest in POJO mode");
}
} else {
ListTranscriptionJobsRequest.Builder builder = ListTranscriptionJobsRequest.builder();
Expand Down Expand Up @@ -265,6 +274,9 @@ private void deleteTranscriptionJob(TranscribeClient transcribeClient, Exchange
LOG.trace("Delete Transcription Job command returned the error code {}", ase.awsErrorDetails().errorCode());
throw ase;
}
} else {
throw new IllegalArgumentException(
"deleteTranscriptionJob operation requires DeleteTranscriptionJobRequest in POJO mode");
}
} else {
DeleteTranscriptionJobRequest.Builder builder = DeleteTranscriptionJobRequest.builder();
Expand Down Expand Up @@ -295,6 +307,9 @@ private void createVocabulary(TranscribeClient transcribeClient, Exchange exchan
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"createVocabulary operation requires CreateVocabularyRequest in POJO mode");
}
} else {
CreateVocabularyRequest.Builder builder = CreateVocabularyRequest.builder();
Expand Down Expand Up @@ -335,6 +350,9 @@ private void getVocabulary(TranscribeClient transcribeClient, Exchange exchange)
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"getVocabulary operation requires GetVocabularyRequest in POJO mode");
}
} else {
GetVocabularyRequest.Builder builder = GetVocabularyRequest.builder();
Expand Down Expand Up @@ -367,6 +385,9 @@ private void listVocabularies(TranscribeClient transcribeClient, Exchange exchan
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"listVocabularies operation requires ListVocabulariesRequest in POJO mode");
}
} else {
ListVocabulariesRequest.Builder builder = ListVocabulariesRequest.builder();
Expand Down Expand Up @@ -399,6 +420,9 @@ private void updateVocabulary(TranscribeClient transcribeClient, Exchange exchan
}
Message message = getMessageForResponse(exchange);
message.setBody(result);
} else {
throw new IllegalArgumentException(
"updateVocabulary operation requires UpdateVocabularyRequest in POJO mode");
}
} else {
UpdateVocabularyRequest.Builder builder = UpdateVocabularyRequest.builder();
Expand Down Expand Up @@ -432,6 +456,9 @@ private void deleteVocabulary(TranscribeClient transcribeClient, Exchange exchan
LOG.trace("Delete Vocabulary command returned the error code {}", ase.awsErrorDetails().errorCode());
throw ase;
}
} else {
throw new IllegalArgumentException(
"deleteVocabulary operation requires DeleteVocabularyRequest in POJO mode");
}
} else {
DeleteVocabularyRequest.Builder builder = DeleteVocabularyRequest.builder();
Expand All @@ -454,6 +481,9 @@ private void createVocabularyFilter(TranscribeClient transcribeClient, Exchange
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof CreateVocabularyFilterRequest req) {
setResponse(exchange, execute("Create Vocabulary Filter", () -> transcribeClient.createVocabularyFilter(req)));
} else {
throw new IllegalArgumentException(
"createVocabularyFilter operation requires CreateVocabularyFilterRequest in POJO mode");
}
} else {
CreateVocabularyFilterRequest.Builder builder = CreateVocabularyFilterRequest.builder();
Expand All @@ -475,6 +505,9 @@ private void getVocabularyFilter(TranscribeClient transcribeClient, Exchange exc
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof GetVocabularyFilterRequest req) {
setResponse(exchange, execute("Get Vocabulary Filter", () -> transcribeClient.getVocabularyFilter(req)));
} else {
throw new IllegalArgumentException(
"getVocabularyFilter operation requires GetVocabularyFilterRequest in POJO mode");
}
} else {
GetVocabularyFilterRequest.Builder builder = GetVocabularyFilterRequest.builder();
Expand All @@ -489,6 +522,9 @@ private void listVocabularyFilters(TranscribeClient transcribeClient, Exchange e
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof ListVocabularyFiltersRequest req) {
setResponse(exchange, execute("List Vocabulary Filters", () -> transcribeClient.listVocabularyFilters(req)));
} else {
throw new IllegalArgumentException(
"listVocabularyFilters operation requires ListVocabularyFiltersRequest in POJO mode");
}
} else {
ListVocabularyFiltersRequest.Builder builder = ListVocabularyFiltersRequest.builder();
Expand All @@ -506,6 +542,9 @@ private void updateVocabularyFilter(TranscribeClient transcribeClient, Exchange
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof UpdateVocabularyFilterRequest req) {
setResponse(exchange, execute("Update Vocabulary Filter", () -> transcribeClient.updateVocabularyFilter(req)));
} else {
throw new IllegalArgumentException(
"updateVocabularyFilter operation requires UpdateVocabularyFilterRequest in POJO mode");
}
} else {
UpdateVocabularyFilterRequest.Builder builder = UpdateVocabularyFilterRequest.builder();
Expand All @@ -527,6 +566,9 @@ private void deleteVocabularyFilter(TranscribeClient transcribeClient, Exchange
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof DeleteVocabularyFilterRequest req) {
setResponse(exchange, execute("Delete Vocabulary Filter", () -> transcribeClient.deleteVocabularyFilter(req)));
} else {
throw new IllegalArgumentException(
"deleteVocabularyFilter operation requires DeleteVocabularyFilterRequest in POJO mode");
}
} else {
DeleteVocabularyFilterRequest.Builder builder = DeleteVocabularyFilterRequest.builder();
Expand All @@ -541,6 +583,9 @@ private void createLanguageModel(TranscribeClient transcribeClient, Exchange exc
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof CreateLanguageModelRequest req) {
setResponse(exchange, execute("Create Language Model", () -> transcribeClient.createLanguageModel(req)));
} else {
throw new IllegalArgumentException(
"createLanguageModel operation requires CreateLanguageModelRequest in POJO mode");
}
} else {
CreateLanguageModelRequest.Builder builder = CreateLanguageModelRequest.builder();
Expand All @@ -562,6 +607,9 @@ private void describeLanguageModel(TranscribeClient transcribeClient, Exchange e
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof DescribeLanguageModelRequest req) {
setResponse(exchange, execute("Describe Language Model", () -> transcribeClient.describeLanguageModel(req)));
} else {
throw new IllegalArgumentException(
"describeLanguageModel operation requires DescribeLanguageModelRequest in POJO mode");
}
} else {
DescribeLanguageModelRequest.Builder builder = DescribeLanguageModelRequest.builder();
Expand All @@ -576,6 +624,9 @@ private void listLanguageModels(TranscribeClient transcribeClient, Exchange exch
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof ListLanguageModelsRequest req) {
setResponse(exchange, execute("List Language Models", () -> transcribeClient.listLanguageModels(req)));
} else {
throw new IllegalArgumentException(
"listLanguageModels operation requires ListLanguageModelsRequest in POJO mode");
}
} else {
ListLanguageModelsRequest.Builder builder = ListLanguageModelsRequest.builder();
Expand All @@ -592,6 +643,9 @@ private void deleteLanguageModel(TranscribeClient transcribeClient, Exchange exc
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof DeleteLanguageModelRequest req) {
setResponse(exchange, execute("Delete Language Model", () -> transcribeClient.deleteLanguageModel(req)));
} else {
throw new IllegalArgumentException(
"deleteLanguageModel operation requires DeleteLanguageModelRequest in POJO mode");
}
} else {
DeleteLanguageModelRequest.Builder builder = DeleteLanguageModelRequest.builder();
Expand All @@ -608,6 +662,9 @@ private void createMedicalVocabulary(TranscribeClient transcribeClient, Exchange
if (payload instanceof CreateMedicalVocabularyRequest req) {
setResponse(exchange,
execute("Create Medical Vocabulary", () -> transcribeClient.createMedicalVocabulary(req)));
} else {
throw new IllegalArgumentException(
"createMedicalVocabulary operation requires CreateMedicalVocabularyRequest in POJO mode");
}
} else {
CreateMedicalVocabularyRequest.Builder builder = CreateMedicalVocabularyRequest.builder();
Expand All @@ -624,6 +681,9 @@ private void getMedicalVocabulary(TranscribeClient transcribeClient, Exchange ex
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof GetMedicalVocabularyRequest req) {
setResponse(exchange, execute("Get Medical Vocabulary", () -> transcribeClient.getMedicalVocabulary(req)));
} else {
throw new IllegalArgumentException(
"getMedicalVocabulary operation requires GetMedicalVocabularyRequest in POJO mode");
}
} else {
GetMedicalVocabularyRequest.Builder builder = GetMedicalVocabularyRequest.builder();
Expand All @@ -640,6 +700,9 @@ private void listMedicalVocabularies(TranscribeClient transcribeClient, Exchange
if (payload instanceof ListMedicalVocabulariesRequest req) {
setResponse(exchange,
execute("List Medical Vocabularies", () -> transcribeClient.listMedicalVocabularies(req)));
} else {
throw new IllegalArgumentException(
"listMedicalVocabularies operation requires ListMedicalVocabulariesRequest in POJO mode");
}
} else {
ListMedicalVocabulariesRequest.Builder builder = ListMedicalVocabulariesRequest.builder();
Expand All @@ -659,6 +722,9 @@ private void updateMedicalVocabulary(TranscribeClient transcribeClient, Exchange
if (payload instanceof UpdateMedicalVocabularyRequest req) {
setResponse(exchange,
execute("Update Medical Vocabulary", () -> transcribeClient.updateMedicalVocabulary(req)));
} else {
throw new IllegalArgumentException(
"updateMedicalVocabulary operation requires UpdateMedicalVocabularyRequest in POJO mode");
}
} else {
UpdateMedicalVocabularyRequest.Builder builder = UpdateMedicalVocabularyRequest.builder();
Expand All @@ -677,6 +743,9 @@ private void deleteMedicalVocabulary(TranscribeClient transcribeClient, Exchange
if (payload instanceof DeleteMedicalVocabularyRequest req) {
setResponse(exchange,
execute("Delete Medical Vocabulary", () -> transcribeClient.deleteMedicalVocabulary(req)));
} else {
throw new IllegalArgumentException(
"deleteMedicalVocabulary operation requires DeleteMedicalVocabularyRequest in POJO mode");
}
} else {
DeleteMedicalVocabularyRequest.Builder builder = DeleteMedicalVocabularyRequest.builder();
Expand All @@ -694,6 +763,9 @@ private void startMedicalTranscriptionJob(TranscribeClient transcribeClient, Exc
setResponse(exchange,
execute("Start Medical Transcription Job",
() -> transcribeClient.startMedicalTranscriptionJob(req)));
} else {
throw new IllegalArgumentException(
"startMedicalTranscriptionJob operation requires StartMedicalTranscriptionJobRequest in POJO mode");
}
} else {
StartMedicalTranscriptionJobRequest.Builder builder = StartMedicalTranscriptionJobRequest.builder();
Expand All @@ -720,6 +792,9 @@ private void getMedicalTranscriptionJob(TranscribeClient transcribeClient, Excha
if (payload instanceof GetMedicalTranscriptionJobRequest req) {
setResponse(exchange,
execute("Get Medical Transcription Job", () -> transcribeClient.getMedicalTranscriptionJob(req)));
} else {
throw new IllegalArgumentException(
"getMedicalTranscriptionJob operation requires GetMedicalTranscriptionJobRequest in POJO mode");
}
} else {
GetMedicalTranscriptionJobRequest.Builder builder = GetMedicalTranscriptionJobRequest.builder();
Expand All @@ -737,6 +812,9 @@ private void listMedicalTranscriptionJobs(TranscribeClient transcribeClient, Exc
if (payload instanceof ListMedicalTranscriptionJobsRequest req) {
setResponse(exchange,
execute("List Medical Transcription Jobs", () -> transcribeClient.listMedicalTranscriptionJobs(req)));
} else {
throw new IllegalArgumentException(
"listMedicalTranscriptionJobs operation requires ListMedicalTranscriptionJobsRequest in POJO mode");
}
} else {
ListMedicalTranscriptionJobsRequest.Builder builder = ListMedicalTranscriptionJobsRequest.builder();
Expand All @@ -756,6 +834,9 @@ private void deleteMedicalTranscriptionJob(TranscribeClient transcribeClient, Ex
if (payload instanceof DeleteMedicalTranscriptionJobRequest req) {
setResponse(exchange, execute("Delete Medical Transcription Job",
() -> transcribeClient.deleteMedicalTranscriptionJob(req)));
} else {
throw new IllegalArgumentException(
"deleteMedicalTranscriptionJob operation requires DeleteMedicalTranscriptionJobRequest in POJO mode");
}
} else {
DeleteMedicalTranscriptionJobRequest.Builder builder = DeleteMedicalTranscriptionJobRequest.builder();
Expand All @@ -771,6 +852,9 @@ private void tagResource(TranscribeClient transcribeClient, Exchange exchange) t
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof TagResourceRequest req) {
setResponse(exchange, execute("Tag Resource", () -> transcribeClient.tagResource(req)));
} else {
throw new IllegalArgumentException(
"tagResource operation requires TagResourceRequest in POJO mode");
}
} else {
TagResourceRequest.Builder builder = TagResourceRequest.builder();
Expand All @@ -790,6 +874,9 @@ private void untagResource(TranscribeClient transcribeClient, Exchange exchange)
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof UntagResourceRequest req) {
setResponse(exchange, execute("Untag Resource", () -> transcribeClient.untagResource(req)));
} else {
throw new IllegalArgumentException(
"untagResource operation requires UntagResourceRequest in POJO mode");
}
} else {
UntagResourceRequest.Builder builder = UntagResourceRequest.builder();
Expand All @@ -807,6 +894,9 @@ private void listTagsForResource(TranscribeClient transcribeClient, Exchange exc
Object payload = exchange.getIn().getMandatoryBody();
if (payload instanceof ListTagsForResourceRequest req) {
setResponse(exchange, execute("List Tags For Resource", () -> transcribeClient.listTagsForResource(req)));
} else {
throw new IllegalArgumentException(
"listTagsForResource operation requires ListTagsForResourceRequest in POJO mode");
}
} else {
ListTagsForResourceRequest.Builder builder = ListTagsForResourceRequest.builder();
Expand Down
Loading