Skip to content

rewrite run #1

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

Open
davidh44 wants to merge 1 commit into
base: main
Choose a base branch
from
Open

rewrite run #1

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 .idea/.gitignore
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

27 changes: 17 additions & 10 deletions pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,9 +15,9 @@
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-bom</artifactId>
<version>1.11.446</version>
<groupId>software.amazon.awssdk</groupId>
<artifactId>bom</artifactId>
<version>2.23.16-SNAPSHOT</version>
<type>pom</type>
<scope>import</scope>
</dependency>
Expand All @@ -40,15 +40,13 @@
</dependency>
<!-- https://mvnrepository.com/artifact/com.amazonaws/aws-java-sdk-dynamodb -->
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-dynamodb</artifactId>
<version>1.11.956</version>
<groupId>software.amazon.awssdk</groupId>
<artifactId>dynamodb</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/com.amazonaws/aws-java-sdk-ecs -->
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-ecs</artifactId>
<version>1.11.956</version>
<groupId>software.amazon.awssdk</groupId>
<artifactId>ecs</artifactId>
</dependency>
<dependency>
<groupId>com.amazonaws</groupId>
Expand Down Expand Up @@ -81,7 +79,16 @@
<artifactId>log4j-core</artifactId>
<version>2.8.2</version>
</dependency>

<dependency>
<groupId>software.amazon.awssdk</groupId>
<artifactId>apache-client</artifactId>
<version>2.23.16-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>software.amazon.awssdk</groupId>
<artifactId>netty-nio-client</artifactId>
<version>2.23.16-SNAPSHOT</version>
</dependency>



Expand Down
41 changes: 20 additions & 21 deletions src/main/java/com/amazonaws/samples/Bootstrap.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,14 +1,13 @@
package com.amazonaws.samples;

import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.model.AttributeValue;
import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
import com.amazonaws.services.sqs.AmazonSQSResponder;
import com.amazonaws.services.sqs.AmazonSQSResponderClientBuilder;
import com.amazonaws.services.sqs.model.AmazonSQSException;
import com.amazonaws.services.sqs.model.CreateQueueRequest;
import software.amazon.awssdk.services.dynamodbv2.DynamoDbClient;
import software.amazon.awssdk.services.dynamodbv2.DynamoDbClientBuilder;
import software.amazon.awssdk.services.dynamodbv2.model.AttributeValue;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.SqsClientBuilder;
import software.amazon.awssdk.services.sqs.SqsResponderClient;
import software.amazon.awssdk.services.sqs.model.SqsException;
import software.amazon.awssdk.services.sqs.model.CreateQueueRequest;
import com.amazonaws.services.sqs.util.SQSMessageConsumer;
import com.amazonaws.services.sqs.util.SQSMessageConsumerBuilder;
import com.jayway.jsonpath.JsonPath;
Expand Down Expand Up @@ -36,17 +35,17 @@ public Bootstrap() {
try {
//insert the queue name and container id in a DynamoDB table
String taskId = getTaskId();
AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
CreateQueueRequest create_request = new CreateQueueRequest(taskId);
SqsClient sqs = SqsClientBuilder.defaultClient();
CreateQueueRequest create_request = CreateQueueRequest.builder().build();
sqs.createQueue(create_request);

queue_url = sqs.getQueueUrl(taskId).getQueueUrl();
AmazonDynamoDB ddbClient = AmazonDynamoDBClientBuilder.defaultClient();
DynamoDbClient ddbClient = DynamoDbClientBuilder.defaultClient();

Map<String, AttributeValue> item_values = new HashMap<String,AttributeValue>();

item_values.put("id", new AttributeValue(taskId));
item_values.put("QueueName", new AttributeValue(taskId));
item_values.put("id", AttributeValue.builder().build());
item_values.put("QueueName", AttributeValue.builder().build());
//item_values.put("id", new AttributeValue(UUID.randomUUID().toString()));

//ddbClient.putItem(SQS_CONTAINER_MAPPING_TABLE,item_values);
Expand All @@ -56,9 +55,9 @@ public Bootstrap() {

}catch(IOException exp){
exp.printStackTrace();
}catch (AmazonSQSException e) {
}catch (SqsException e) {
e.printStackTrace();
if (!e.getErrorCode().equals("QueueAlreadyExists")) {
if (!e.awsErrorDetails().errorCode().equals("QueueAlreadyExists")) {
throw e;
}
}
Expand Down Expand Up @@ -104,17 +103,17 @@ public void processMessages() {
//String queueUrl = "https://sqs.us-west-2.amazonaws.com/681921237057/sns-subsciption-test";
System.out.println("Starting up consumer using queue: " + queue_url);

AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
AmazonSQSResponder responder = AmazonSQSResponderClientBuilder.standard()
.withAmazonSQS(sqs)
SqsClient sqs = SqsClientBuilder.defaultClient();
SqsResponderClient responder = SqsResponderClient.builder()
.amazonSqs(sqs)
.build();

SQSMessageConsumer consumer = SQSMessageConsumerBuilder.standard()
.withAmazonSQS(responder.getAmazonSQS())
.withQueueUrl(queue_url)
.withConsumer(message -> {
System.out.println("The message is " + message.getBody());
sqs.deleteMessage(queue_url,message.getReceiptHandle());
System.out.println("The message is " + message.body());
sqs.deleteMessage(queue_url,message.receiptHandle());

}).build();
consumer.start();
Expand Down