Skip to content

[PRM-666] REVERTED - Gone back to AWS SDK v1 due to extended client#316

Open
AndyFlintAnswerDigital wants to merge 1 commit intomainfrom
PRM-666
Open

[PRM-666] REVERTED - Gone back to AWS SDK v1 due to extended client#316
AndyFlintAnswerDigital wants to merge 1 commit intomainfrom
PRM-666

Conversation

@AndyFlintAnswerDigital
Copy link
Copy Markdown
Contributor

No description provided.

@AndyFlintAnswerDigital AndyFlintAnswerDigital requested a review from a team as a code owner March 31, 2026 17:32
@github-actions
Copy link
Copy Markdown

Code security issues found

View full details here.

@sonarqubecloud
Copy link
Copy Markdown

public static SqsClient sqsClient(@Value("${localstack.url}") String localstackUrl) throws URISyntaxException {
return SqsClient.builder()
.credentialsProvider(() -> AwsBasicCredentials.create("LSIAQAAAAAAVNCBMPNSG", "LSIAQAAAAAAVNCBMPNSG"))
.credentialsProvider((()-> AwsBasicCredentials.create("LSIAQAAAAAAVNCBMPNSG", "LSIAQAAAAAAVNCBMPNSG")))
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Does this need an extra bracket?

PublishResponse response = snsClient.publish(request);
String[] topicAttributes = topicArn.split(":");
log.info("PUBLISHED: message to {} topic. Published SNS message id: {}", topicAttributes[topicAttributes.length - 1], response.messageId());
var result = snsClient.publish(request);
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

var?


@Bean
public AmazonSNSExtendedClient s3SupportedSnsClient(AmazonSNS snsClient, AmazonS3 s3) {
var snsExtendedClientConfiguration = new SNSExtendedClientConfiguration()
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

var?


@Bean
public AmazonSQSExtendedClient s3SupportedSqsClient(AmazonSQSAsync sqsClient, AmazonS3 s3) {
var extendedClientConfiguration = new ExtendedClientConfiguration().withPayloadSupportEnabled(s3, bucketName, true);
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

var?


@Bean
public SQSConnection createConnection(AmazonSQSAsync amazonSQSAsync) throws JMSException {
var connectionFactory = new SQSConnectionFactory(new ProviderConfiguration(), amazonSQSAsync);
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

var?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants