Skip to content

Commit

Permalink
Ab2d/spring boot events exception (#424)
Browse files Browse the repository at this point in the history
* Added message converter to SqsMessageListenerContainerFactory
  • Loading branch information
smirnovaae authored Jan 15, 2025
1 parent abd3457 commit 95d3005
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@
import gov.cms.ab2d.eventclient.config.Ab2dEnvironment;
import io.awspring.cloud.sqs.config.SqsBootstrapConfiguration;
import io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory;
import io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
Expand Down Expand Up @@ -54,10 +55,12 @@ public SQSConfig(@Value("${cloud.aws.region.static}") String region,
}

@Bean
public SqsMessageListenerContainerFactory<Object> defaultSqsListenerContainerFactory() {
public SqsMessageListenerContainerFactory<Object> defaultSqsListenerContainerFactory(SqsAsyncClient sqsAsyncClient) {
return SqsMessageListenerContainerFactory
.builder()
.sqsAsyncClient(amazonSQSAsync())
.configure(options -> options
.messageConverter(sqsMessagingMessageConverter()))
.sqsAsyncClient(sqsAsyncClient)
.build();
}

Expand Down Expand Up @@ -105,6 +108,12 @@ protected MessageConverter messageConverter() {
return jacksonMessageConverter;
}

private SqsMessagingMessageConverter sqsMessagingMessageConverter() {
SqsMessagingMessageConverter converter = new SqsMessagingMessageConverter();
converter.setPayloadMessageConverter(messageConverter());
return converter;
}

public SqsAsyncClient createQueue(SqsAsyncClient sqsClient) {
try {
CreateQueueRequest createQueueRequest = CreateQueueRequest.builder()
Expand Down
4 changes: 2 additions & 2 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -23,10 +23,10 @@ ext {

// AB2D libraries
fhirVersion='2.1.0'
bfdVersion='2.6.0'
bfdVersion='3.2.0'
aggregatorVersion='2.0.1'
filtersVersion='2.1.0'
eventClientVersion='3.2.1'
eventClientVersion='3.2.2'
propertiesClientVersion='2.0.0'
contractClientVersion='2.0.0'
snsClientVersion='1.0.0'
Expand Down

0 comments on commit 95d3005

Please sign in to comment.