Skip to content

Commit d1d3368

Browse files
committed
Add support for Kinesis ARNs
1 parent 1f153b1 commit d1d3368

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

src/main/java/gov/nasa/cumulus/KinesisSender.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,13 @@ public void sendMessage(String response, String endpoint) {
3333
return;
3434
}
3535
PutRecordRequest putRecord = new PutRecordRequest();
36-
putRecord.setStreamName(endpoint);
36+
37+
if (endpoint.startsWith("arn:aws:kinesis:")) {
38+
putRecord.setStreamARN(endpoint);
39+
} else {
40+
putRecord.setStreamName(endpoint);
41+
}
42+
3743
putRecord.setPartitionKey("1");
3844
putRecord.setData(ByteBuffer.wrap(bytes));
3945
this.kinesisClient.putRecord(putRecord);

0 commit comments

Comments
 (0)