Details
-
New Feature
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.9.1
-
None
Description
After a jclouds forum inquiry it appears that "MessageAttributes" are not currently supported in the jclouds SQS implementation.
For example when using the AWS API I can include message attributes when I send a message like below. However. I cannot find an equivalent API in jclouds.
AWSCredentials credentials = Aws.getAwsCredentials(accessKey, secretKey);
AmazonSQSClient sqs = new AmazonSQSClient(credentials);
sqs.setRegion(Region.getRegion(Regions.US_EAST_1));
SendMessageRequest smr = new SendMessageRequest();
smr.withQueueUrl(url);
smr.setMessageBody(messageBody);
for (Map.Entry<String, String> entry : map.entrySet()) {
System.out.println(entry.getKey() + " :: " + entry.getValue());
MessageAttributeValue mav = new MessageAttributeValue();
mav.setStringValue(entry.getValue());
mav.setDataType("String");
smr.addMessageAttributesEntry(entry.getKey(), mav);
}
SendMessageResult x = sqs.sendMessage(smr);
System.out.println("SQS message published..." + x.getMessageId());
}