11// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
22// SPDX-License-Identifier: Apache-2.0
33
4- import aws.sdk.kotlin.runtime.auth.credentials.EnvironmentCredentialsProvider
54import aws.sdk.kotlin.services.secretsmanager.SecretsManagerClient
65import aws.sdk.kotlin.services.secretsmanager.model.GetSecretValueRequest
76import com.google.gson.Gson
@@ -24,11 +23,14 @@ import org.junit.jupiter.api.Order
2423import org.junit.jupiter.api.Test
2524import org.junit.jupiter.api.TestInstance
2625import org.junit.jupiter.api.TestMethodOrder
26+ import org.slf4j.Logger
27+ import org.slf4j.LoggerFactory
2728import java.util.Random
2829
2930@TestInstance(TestInstance .Lifecycle .PER_CLASS )
3031@TestMethodOrder(OrderAnnotation ::class )
3132class SQSTest {
33+ private val logger: Logger = LoggerFactory .getLogger(SQSTest ::class .java)
3234 private var queueName = " "
3335 private var message = " "
3436 private var queueUrl = " "
@@ -45,16 +47,6 @@ class SQSTest {
4547 val queueMessage = gson.fromJson(json, QueueMessage ::class .java)
4648 queueName = queueMessage.queueName.toString() + randomNum
4749 message = queueMessage.message.toString()
48-
49- /*
50- val input: InputStream = this.javaClass.getClassLoader().getResourceAsStream("config.properties")
51- val prop = Properties()
52-
53- // load the properties file.
54- prop.load(input)
55- queueName = prop.getProperty("QueueName")
56- message = prop.getProperty("Message")
57- */
5850 }
5951
6052 @Test
@@ -63,71 +55,71 @@ class SQSTest {
6355 runBlocking {
6456 queueUrl = createQueue(queueName)
6557 Assertions .assertTrue(! queueUrl.isEmpty())
66- println (" Test 1 passed" )
58+ logger.info (" Test 1 passed" )
6759 }
6860
6961 @Test
7062 @Order(2 )
7163 fun sendMessageTest () =
7264 runBlocking {
7365 sendMessages(queueUrl, message)
74- println (" Test 2 passed" )
66+ logger.info (" Test 2 passed" )
7567 }
7668
7769 @Test
7870 @Order(3 )
7971 fun sendBatchMessagesTest () =
8072 runBlocking {
8173 sendBatchMessages(queueUrl)
82- println (" Test 3 passed" )
74+ logger.info (" Test 3 passed" )
8375 }
8476
8577 @Test
8678 @Order(4 )
8779 fun getMessageTest () =
8880 runBlocking {
8981 receiveMessages(queueUrl)
90- println (" Test 4 passed" )
82+ logger.info (" Test 4 passed" )
9183 }
9284
9385 @Test
9486 @Order(5 )
9587 fun addQueueTagsTest () =
9688 runBlocking {
9789 addTags(queueName)
98- println (" Test 5 passed" )
90+ logger.info (" Test 5 passed" )
9991 }
10092
10193 @Test
10294 @Order(6 )
10395 fun listQueueTagsTest () =
10496 runBlocking {
10597 listTags(queueName)
106- println (" Test 6 passed" )
98+ logger.info (" Test 6 passed" )
10799 }
108100
109101 @Test
110102 @Order(7 )
111103 fun removeQueueTagsTest () =
112104 runBlocking {
113105 removeTag(queueName, " Test" )
114- println (" Test 7 passed" )
106+ logger.info (" Test 7 passed" )
115107 }
116108
117109 @Test
118110 @Order(8 )
119111 fun deleteMessagesTest () =
120112 runBlocking {
121113 deleteMessages(queueUrl)
122- println (" Test 8 passed" )
114+ logger.info (" Test 8 passed" )
123115 }
124116
125117 @Test
126118 @Order(9 )
127119 fun deleteQueueTest () =
128120 runBlocking {
129121 deleteQueue(queueUrl)
130- println (" Test 9 passed" )
122+ logger.info (" Test 9 passed" )
131123 }
132124
133125 private suspend fun getSecretValues (): String {
@@ -138,7 +130,6 @@ class SQSTest {
138130 }
139131 SecretsManagerClient {
140132 region = " us-east-1"
141- credentialsProvider = EnvironmentCredentialsProvider ()
142133 }.use { secretClient ->
143134 val valueResponse = secretClient.getSecretValue(valueRequest)
144135 return valueResponse.secretString.toString()
0 commit comments