Skip to content

Commit 00bd66f

Browse files
authored
Merge pull request #644 from aws/finks/iot
Changing to call describe endpoint
2 parents efde633 + 43587bd commit 00bd66f

File tree

2 files changed

+15
-1
lines changed

2 files changed

+15
-1
lines changed

services/iotdataplane/pom.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,12 @@
5858
<artifactId>protocol-core</artifactId>
5959
<version>${awsjavasdk.version}</version>
6060
</dependency>
61+
<dependency>
62+
<groupId>software.amazon.awssdk</groupId>
63+
<artifactId>iot</artifactId>
64+
<version>${awsjavasdk.version}</version>
65+
<scope>test</scope>
66+
</dependency>
6167
</dependencies>
6268

6369
</project>

services/iotdataplane/src/it/java/software/amazon/awssdk/services/iotdataplane/ServiceIntegrationTest.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,13 @@
2222
import com.fasterxml.jackson.databind.JsonNode;
2323
import com.fasterxml.jackson.databind.ObjectMapper;
2424
import java.io.IOException;
25+
import java.net.URI;
2526
import java.nio.ByteBuffer;
2627
import org.junit.Before;
2728
import org.junit.Test;
2829
import software.amazon.awssdk.core.SdkBytes;
2930
import software.amazon.awssdk.regions.Region;
31+
import software.amazon.awssdk.services.iot.IotClient;
3032
import software.amazon.awssdk.services.iotdataplane.model.DeleteThingShadowRequest;
3133
import software.amazon.awssdk.services.iotdataplane.model.DeleteThingShadowResponse;
3234
import software.amazon.awssdk.services.iotdataplane.model.GetThingShadowRequest;
@@ -73,7 +75,13 @@ private static void assertPayloadIsValid(SdkBytes originalPayload, SdkBytes retu
7375

7476
@Before
7577
public void setup() throws Exception {
76-
iot = IotDataPlaneClient.builder().credentialsProvider(CREDENTIALS_PROVIDER_CHAIN).region(Region.US_EAST_1).build();
78+
IotClient client = IotClient.builder().credentialsProvider(CREDENTIALS_PROVIDER_CHAIN).region(Region.US_EAST_1).build();
79+
String endpoint = client.describeEndpoint(r -> r.endpointType("iot:Data-ATS")).endpointAddress();
80+
iot = IotDataPlaneClient.builder()
81+
.credentialsProvider(CREDENTIALS_PROVIDER_CHAIN)
82+
.endpointOverride(URI.create("https://" + endpoint))
83+
.region(Region.US_EAST_1)
84+
.build();
7785
}
7886

7987
@Test

0 commit comments

Comments
 (0)