You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@jclouds.apache.org by "Andrew Gaul (JIRA)" <ji...@apache.org> on 2015/11/10 23:03:11 UTC

[jira] [Updated] (JCLOUDS-1034) AWS SQS - MessageAttributes not currently supported

     [ https://issues.apache.org/jira/browse/JCLOUDS-1034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Andrew Gaul updated JCLOUDS-1034:
---------------------------------
    Summary: AWS SQS - MessageAttributes not currently supported  (was: AWS SQS - MessagAttributes not currently supprted)

> AWS SQS - MessageAttributes not currently supported
> ---------------------------------------------------
>
>                 Key: JCLOUDS-1034
>                 URL: https://issues.apache.org/jira/browse/JCLOUDS-1034
>             Project: jclouds
>          Issue Type: Improvement
>          Components: jclouds-labs-aws
>    Affects Versions: 1.9.1
>            Reporter: Massimo Mirabito
>            Priority: Blocker
>
> After a Jcloud forum inquiry it appears that "MessaegAttributes"  are not currently supported in the Jcloud 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 JCloud.
>     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());
>      }



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)