com.amazonaws.services.sqs.model.Message.getAttributes()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(142)

本文整理了Java中com.amazonaws.services.sqs.model.Message.getAttributes()方法的一些代码示例，展示了Message.getAttributes()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.getAttributes()方法的具体详情如下：
包路径：com.amazonaws.services.sqs.model.Message
类名称：Message
方法名：getAttributes

Message.getAttributes介绍

[英]SenderId, SentTimestamp, ApproximateReceiveCount, and/or ApproximateFirstReceiveTimestamp. SentTimestamp and ApproximateFirstReceiveTimestamp are each returned as an integer representing the epoch time in milliseconds.
[中]SenderId、SentTimestamp、ApproximateReceiveCount和/或ApproximateFirstReceiveTimestamp。SentTimestamp和ApproximateFirstReceiveTimestamp都以整数形式返回，以毫秒为单位表示epoch time。

代码示例

代码示例来源：origin: aws/aws-sdk-java

  1. /**
  2.  * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be
  3.  * redacted from this string using a placeholder value.
  4.  *
  5.  * @return A string representation of this object.
  6.  *
  7.  * @see java.lang.Object#toString()
  8.  */
  9. @Override
  10. public String toString() {
  11.   StringBuilder sb = new StringBuilder();
  12.   sb.append("{");
  13.   if (getMessageId() != null)
  14.     sb.append("MessageId: ").append(getMessageId()).append(",");
  15.   if (getReceiptHandle() != null)
  16.     sb.append("ReceiptHandle: ").append(getReceiptHandle()).append(",");
  17.   if (getMD5OfBody() != null)
  18.     sb.append("MD5OfBody: ").append(getMD5OfBody()).append(",");
  19.   if (getBody() != null)
  20.     sb.append("Body: ").append(getBody()).append(",");
  21.   if (getAttributes() != null)
  22.     sb.append("Attributes: ").append(getAttributes()).append(",");
  23.   if (getMD5OfMessageAttributes() != null)
  24.     sb.append("MD5OfMessageAttributes: ").append(getMD5OfMessageAttributes()).append(",");
  25.   if (getMessageAttributes() != null)
  26.     sb.append("MessageAttributes: ").append(getMessageAttributes());
  27.   sb.append("}");
  28.   return sb.toString();
  29. }

代码示例来源：origin: aws/aws-sdk-java

  1. @Override
  2. public int hashCode() {
  3.   final int prime = 31;
  4.   int hashCode = 1;
  5.   hashCode = prime * hashCode + ((getMessageId() == null) ? 0 : getMessageId().hashCode());
  6.   hashCode = prime * hashCode + ((getReceiptHandle() == null) ? 0 : getReceiptHandle().hashCode());
  7.   hashCode = prime * hashCode + ((getMD5OfBody() == null) ? 0 : getMD5OfBody().hashCode());
  8.   hashCode = prime * hashCode + ((getBody() == null) ? 0 : getBody().hashCode());
  9.   hashCode = prime * hashCode + ((getAttributes() == null) ? 0 : getAttributes().hashCode());
  10.   hashCode = prime * hashCode + ((getMD5OfMessageAttributes() == null) ? 0 : getMD5OfMessageAttributes().hashCode());
  11.   hashCode = prime * hashCode + ((getMessageAttributes() == null) ? 0 : getMessageAttributes().hashCode());
  12.   return hashCode;
  13. }

代码示例来源：origin: apache/usergrid

  1. message.getAttributes().get( "type" ) );
  2. queueMessage.setStringBody( originalBody );
  3. int receiveCount = Integer.valueOf(message.getAttributes().get("ApproximateReceiveCount"));
  4. queueMessage.setReceiveCount( receiveCount );
  5. queueMessages.add( queueMessage );

代码示例来源：origin: aws/aws-sdk-java

  1. if (other.getBody() != null && other.getBody().equals(this.getBody()) == false)
  2.   return false;
  3. if (other.getAttributes() == null ^ this.getAttributes() == null)
  4.   return false;
  5. if (other.getAttributes() != null && other.getAttributes().equals(this.getAttributes()) == false)
  6.   return false;
  7. if (other.getMD5OfMessageAttributes() == null ^ this.getMD5OfMessageAttributes() == null)

代码示例来源：origin: apache/nifi

  1. for (final Map.Entry<String, String> entry : message.getAttributes().entrySet()) {
  2.   attributes.put("sqs." + entry.getKey(), entry.getValue());

代码示例来源：origin: aws-amplify/aws-sdk-android

  1. @Override
  2. public int hashCode() {
  3.   final int prime = 31;
  4.   int hashCode = 1;
  5.   hashCode = prime * hashCode + ((getMessageId() == null) ? 0 : getMessageId().hashCode());
  6.   hashCode = prime * hashCode
  7.       + ((getReceiptHandle() == null) ? 0 : getReceiptHandle().hashCode());
  8.   hashCode = prime * hashCode + ((getMD5OfBody() == null) ? 0 : getMD5OfBody().hashCode());
  9.   hashCode = prime * hashCode + ((getBody() == null) ? 0 : getBody().hashCode());
  10.   hashCode = prime * hashCode + ((getAttributes() == null) ? 0 : getAttributes().hashCode());
  11.   hashCode = prime
  12.       * hashCode
  13.       + ((getMD5OfMessageAttributes() == null) ? 0 : getMD5OfMessageAttributes()
  14.           .hashCode());
  15.   hashCode = prime * hashCode
  16.       + ((getMessageAttributes() == null) ? 0 : getMessageAttributes().hashCode());
  17.   return hashCode;
  18. }

代码示例来源：origin: aws-amplify/aws-sdk-android

  1. /**
  2.  * Returns a string representation of this object; useful for testing and
  3.  * debugging.
  4.  *
  5.  * @return A string representation of this object.
  6.  * @see java.lang.Object#toString()
  7.  */
  8. @Override
  9. public String toString() {
  10.   StringBuilder sb = new StringBuilder();
  11.   sb.append("{");
  12.   if (getMessageId() != null)
  13.     sb.append("MessageId: " + getMessageId() + ",");
  14.   if (getReceiptHandle() != null)
  15.     sb.append("ReceiptHandle: " + getReceiptHandle() + ",");
  16.   if (getMD5OfBody() != null)
  17.     sb.append("MD5OfBody: " + getMD5OfBody() + ",");
  18.   if (getBody() != null)
  19.     sb.append("Body: " + getBody() + ",");
  20.   if (getAttributes() != null)
  21.     sb.append("Attributes: " + getAttributes() + ",");
  22.   if (getMD5OfMessageAttributes() != null)
  23.     sb.append("MD5OfMessageAttributes: " + getMD5OfMessageAttributes() + ",");
  24.   if (getMessageAttributes() != null)
  25.     sb.append("MessageAttributes: " + getMessageAttributes());
  26.   sb.append("}");
  27.   return sb.toString();
  28. }

代码示例来源：origin: aws-amplify/aws-sdk-android

  1. if (other.getBody() != null && other.getBody().equals(this.getBody()) == false)
  2.   return false;
  3. if (other.getAttributes() == null ^ this.getAttributes() == null)
  4.   return false;
  5. if (other.getAttributes() != null
  6.     && other.getAttributes().equals(this.getAttributes()) == false)
  7.   return false;
  8. if (other.getMD5OfMessageAttributes() == null ^ this.getMD5OfMessageAttributes() == null)

代码示例来源：origin: aws/aws-cloudtrail-processing-library

  1. /**
  2.  * Retrieve the CloudTrailSource attributes.
  3.  */
  4. @Override
  5. public Map<String, String> getSourceAttributes() {
  6.   return sqsMessage.getAttributes();
  7. }

代码示例来源：origin: skyscreamer/nevado

  1. @Override
  2.   public Map<String, String> getAttributes() {
  3.     return _message.getAttributes();
  4.   }
  5. }

代码示例来源：origin: aws-amplify/aws-sdk-android

  1. request.addParameter(prefix, StringUtils.fromString(body));
  2. if (_message.getAttributes() != null) {
  3.   prefix = _prefix + "Attribute";
  4.   java.util.Map<String, String> attributes = _message.getAttributes();
  5.   int attributesIndex = 1;
  6.   String attributesPrefix = prefix + ".";

代码示例来源：origin: spring-cloud/spring-cloud-aws

  1. private static Map<String, Object> getAttributesAsMessageHeaders(com.amazonaws.services.sqs.model.Message message) {
  2.   Map<String, Object> messageHeaders = new HashMap<>();
  3.   for (Map.Entry<String, String> attributeKeyValuePair : message.getAttributes().entrySet()) {
  4.     messageHeaders.put(attributeKeyValuePair.getKey(), attributeKeyValuePair.getValue());
  5.   }
  6.   return messageHeaders;
  7. }

代码示例来源：origin: org.springframework.cloud/spring-cloud-aws-messaging

  1. private static Map<String, Object> getAttributesAsMessageHeaders(com.amazonaws.services.sqs.model.Message message) {
  2.   Map<String, Object> messageHeaders = new HashMap<>();
  3.   for (Map.Entry<String, String> attributeKeyValuePair : message.getAttributes().entrySet()) {
  4.     messageHeaders.put(attributeKeyValuePair.getKey(), attributeKeyValuePair.getValue());
  5.   }
  6.   return messageHeaders;
  7. }

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-amazon-web-services

  1. private Instant getTimestamp(final Message message) {
  2.   return new Instant(
  3.     Long.parseLong(
  4.       message.getAttributes().get(MessageSystemAttributeName.SentTimestamp.toString())));
  5.  }
  6. }

代码示例来源：origin: io.macgyver.rx-aws/rx-aws

  1. public static Selector arn(String arn) {
  2.   return Selectors.predicate(it -> {
  3.     if (it instanceof SQSMessage) {
  4.       String arnx = ((SQSMessage) it).getMessage().getAttributes().getOrDefault("arn", null);
  5.       if (arnx != null && arnx.equals(arn)) {
  6.         return true;
  7.       }
  8.     }
  9.     return false;
  10.   });
  11. }

代码示例来源：origin: payara/Cloud-Connectors

  1. @OnSQSMessage
  2.   public void receiveMessage(Message message) {
  3.     System.out.println("Got message " + message.getBody());
  4.     Map<String,MessageAttributeValue> mattrs = message.getMessageAttributes();
  5.     for (String key : mattrs.keySet()) {
  6.       System.out.println("Got Message attribute " + key + "," + mattrs.get(key).getStringValue());
  7.     }
  8.     
  9.     Map<String,String> attrs = message.getAttributes();
  10.     for (String key : attrs.keySet()) {
  11.       System.out.println("Got attribute " + key + "," + attrs.get(key));
  12.     }
  13.   }
  14. }

代码示例来源：origin: com.amazonaws/aws-java-sdk-sqs

  1. @Override
  2. public int hashCode() {
  3.   final int prime = 31;
  4.   int hashCode = 1;
  5.   hashCode = prime * hashCode + ((getMessageId() == null) ? 0 : getMessageId().hashCode());
  6.   hashCode = prime * hashCode + ((getReceiptHandle() == null) ? 0 : getReceiptHandle().hashCode());
  7.   hashCode = prime * hashCode + ((getMD5OfBody() == null) ? 0 : getMD5OfBody().hashCode());
  8.   hashCode = prime * hashCode + ((getBody() == null) ? 0 : getBody().hashCode());
  9.   hashCode = prime * hashCode + ((getAttributes() == null) ? 0 : getAttributes().hashCode());
  10.   hashCode = prime * hashCode + ((getMD5OfMessageAttributes() == null) ? 0 : getMD5OfMessageAttributes().hashCode());
  11.   hashCode = prime * hashCode + ((getMessageAttributes() == null) ? 0 : getMessageAttributes().hashCode());
  12.   return hashCode;
  13. }

代码示例来源：origin: aws/aws-cloudtrail-processing-library

  1. /**
  2.  * Add the account ID attribute to the <code>sqsMessage</code> if it does not exist.
  3.  * @param sqsMessage The SQS message.
  4.  * @param s3ObjectKey The S3 object key.
  5.  */
  6. public static void setMessageAccountId(Message sqsMessage, String s3ObjectKey) {
  7.   if (!sqsMessage.getAttributes().containsKey(SourceAttributeKeys.ACCOUNT_ID.getAttributeKey())) {
  8.     String accountId = extractAccountIdFromObjectKey(s3ObjectKey);
  9.     if (accountId != null) {
  10.       sqsMessage.addAttributesEntry(SourceAttributeKeys.ACCOUNT_ID.getAttributeKey(), accountId);
  11.     }
  12.   }
  13. }

代码示例来源：origin: com.amazonaws/aws-android-sdk-sqs

  1. @Override
  2. public int hashCode() {
  3.   final int prime = 31;
  4.   int hashCode = 1;
  5.   hashCode = prime * hashCode + ((getMessageId() == null) ? 0 : getMessageId().hashCode());
  6.   hashCode = prime * hashCode
  7.       + ((getReceiptHandle() == null) ? 0 : getReceiptHandle().hashCode());
  8.   hashCode = prime * hashCode + ((getMD5OfBody() == null) ? 0 : getMD5OfBody().hashCode());
  9.   hashCode = prime * hashCode + ((getBody() == null) ? 0 : getBody().hashCode());
  10.   hashCode = prime * hashCode + ((getAttributes() == null) ? 0 : getAttributes().hashCode());
  11.   hashCode = prime
  12.       * hashCode
  13.       + ((getMD5OfMessageAttributes() == null) ? 0 : getMD5OfMessageAttributes()
  14.           .hashCode());
  15.   hashCode = prime * hashCode
  16.       + ((getMessageAttributes() == null) ? 0 : getMessageAttributes().hashCode());
  17.   return hashCode;
  18. }

代码示例来源：origin: pinterest/soundwave

  1. public boolean processMessage(Message msg) {
  2.  try {
  3.   MessageProcessingResult result = null;
  4.   NotificationEvent event =
  5.     objectMapper.readValue(msg.getBody(), NotificationEvent.class);
  6.   logger.info("Receive event {} with state {} created at {}",
  7.     event.getDetail().getInstanceId(),
  8.     event.getDetail().getState(), event.getTime());
  9.   sqsEventLogger.info(objectMapper.writeValueAsString(event));
  10.   Map<String, String> attributes = msg.getAttributes();
  11.   if (attributes.containsKey("SentTimestamp")) {
  12.    DateTime sentTime = new DateTime(Long.parseLong(attributes.get("SentTimestamp")),
  13.      DateTimeZone.UTC);
  14.    event.setSqsSentTime(sentTime.toDate());
  15.   }
  16.   if (handler != null) {
  17.    result = handler.processEvent(event);
  18.    if (result != null) {
  19.     messageProcessingLogger.info(objectMapper.writeValueAsString(result));
  20.     return result.isSucceed();
  21.    }
  22.   }
  23.  } catch (Exception e) {
  24.   logger.warn("Error Process message:{}", ExceptionUtils.getRootCauseMessage(e));
  25.  }
  26.  return false;
  27. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com