diff --git a/pom.xml b/pom.xml index 803b522a7e..369bd56d4c 100644 --- a/pom.xml +++ b/pom.xml @@ -168,6 +168,28 @@ + + com.amazonaws + aws-java-sdk + 1.12.604 + + + com.amazonaws + aws-java-sdk-sns + 1.12.604 + + + + software.amazon.awssdk + auth + 2.21.37 + + + + com.amazonaws + aws-java-sdk-core + 1.12.604 + jakarta.xml.bind diff --git a/repository/src/main/java/org/alfresco/repo/event2/SNS.java b/repository/src/main/java/org/alfresco/repo/event2/SNS.java new file mode 100644 index 0000000000..2bf4033d08 --- /dev/null +++ b/repository/src/main/java/org/alfresco/repo/event2/SNS.java @@ -0,0 +1,31 @@ +package org.alfresco.repo.event2; +import com.amazonaws.auth.AWSStaticCredentialsProvider; +import com.amazonaws.auth.BasicAWSCredentials; +import com.amazonaws.services.sns.AmazonSNSClient; +import com.amazonaws.services.sns.AmazonSNSClientBuilder; +import com.amazonaws.services.sns.model.PublishRequest; +public class SNS { + public static void main(String[] args) + { + try { + String TOPIC_ARN = ""; + String AWS_ACCESS_KEY = ""; + String AWS_SECRET_KEY = ""; + String AWS_REGION = ""; + String MESSAGE = "Hey! Manish Connection is established"; + + AmazonSNSClient amazonSNSClient = (AmazonSNSClient) AmazonSNSClientBuilder + .standard() + .withRegion(AWS_REGION) + .withCredentials(new AWSStaticCredentialsProvider( + new BasicAWSCredentials(AWS_ACCESS_KEY, AWS_SECRET_KEY))) + .build(); + PublishRequest request = new PublishRequest(TOPIC_ARN, MESSAGE); + amazonSNSClient.publish(request); + } + catch(Exception e) + { + System.out.print(e.getMessage()); + } + } +}