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

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

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

Message.getMessageId介绍

[英]A unique identifier for the message. Message IDs are considered unique across all AWS accounts for an extended period of time.
[中]消息的唯一标识符。在很长一段时间内，所有AWS帐户中的消息ID都被认为是唯一的。

代码示例

代码示例来源：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: Netflix/conductor

  1. @VisibleForTesting
  2. List<Message> receiveMessages() {
  3.   try {
  4.     ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest()
  5.         .withQueueUrl(queueURL)
  6.         .withVisibilityTimeout(visibilityTimeoutInSeconds)
  7.         .withMaxNumberOfMessages(batchSize);
  8.     ReceiveMessageResult result = client.receiveMessage(receiveMessageRequest);
  9.     List<Message> messages = result.getMessages().stream()
  10.         .map(msg -> new Message(msg.getMessageId(), msg.getBody(), msg.getReceiptHandle()))
  11.         .collect(Collectors.toList());
  12.     Monitors.recordEventQueueMessagesProcessed(QUEUE_TYPE, this.queueName, messages.size());
  13.     return messages;
  14.   } catch (Exception e) {
  15.     logger.error("Exception while getting messages from SQS", e);
  16.     Monitors.recordObservableQMessageReceivedErrors(QUEUE_TYPE);
  17.   }
  18.   return new ArrayList<>();
  19. }

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

  1. LegacyQueueMessage queueMessage = new LegacyQueueMessage( message.getMessageId(), message.getReceiptHandle(), payload,
  2.   message.getAttributes().get( "type" ) );
  3. queueMessage.setStringBody( originalBody );

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

  1. return false;
  2. Message other = (Message) obj;
  3. if (other.getMessageId() == null ^ this.getMessageId() == null)
  4.   return false;
  5. if (other.getMessageId() != null && other.getMessageId().equals(this.getMessageId()) == false)
  6.   return false;
  7. if (other.getReceiptHandle() == null ^ this.getReceiptHandle() == null)

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

  1. attributes.put("sqs.message.id", message.getMessageId());
  2. attributes.put("sqs.receipt.handle", message.getReceiptHandle());
  3. for (final Message message : messages) {
  4.   final DeleteMessageBatchRequestEntry entry = new DeleteMessageBatchRequestEntry();
  5.   entry.setId(message.getMessageId());
  6.   entry.setReceiptHandle(message.getReceiptHandle());
  7.   deleteRequestEntries.add(entry);

代码示例来源：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. Message other = (Message) obj;
  2. if (other.getMessageId() == null ^ this.getMessageId() == null)
  3.   return false;
  4. if (other.getMessageId() != null
  5.     && other.getMessageId().equals(this.getMessageId()) == false)
  6.   return false;
  7. if (other.getReceiptHandle() == null ^ this.getReceiptHandle() == null)

代码示例来源：origin: org.symphonyoss.s2.fugue/aws-fugue

  1. @Override
  2. public String getMessageId()
  3. {
  4.  return message_.getMessageId();
  5. }

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

  1. public void marshall(Message _message, Request<?> request, String _prefix) {
  2.   String prefix;
  3.   if (_message.getMessageId() != null) {
  4.     prefix = _prefix + "MessageId";
  5.     String messageId = _message.getMessageId();
  6.     request.addParameter(prefix, StringUtils.fromString(messageId));

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

  1. @Override
  2. public String getMessageId() {
  3.   return _message.getMessageId();
  4. }

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

  1. @Override
  2. public byte[] getCurrentRecordId() throws NoSuchElementException {
  3.  if (current == null) {
  4.   throw new NoSuchElementException();
  5.  }
  6.  return current.getMessageId().getBytes(StandardCharsets.UTF_8);
  7. }

代码示例来源：origin: awslabs/aws-serverless-sqs-event-source

  1. private SQSMessageResult processMessage(final Message message) {
  2.     try {
  3.       T body = deserializer.deserialize(message);
  4.       delegate.accept(body);
  5.       return new SQSMessageResult(message.getMessageId(), SQSMessageResult.Status.SUCCESS);
  6.     } catch (RetryMessageException e) {
  7.       log.info("Retrying message {}", message, e);
  8.       return new SQSMessageResult(message.getMessageId(), SQSMessageResult.Status.RETRY, e.getRetryDelayInSeconds());
  9.     } catch (Exception e) {
  10.       log.error("Unhandled exception while processing message {}", message, e);
  11.       return new SQSMessageResult(message.getMessageId(), SQSMessageResult.Status.ERROR);
  12.     }
  13.   }
  14. }

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

  1. public static Message<String> createMessage(com.amazonaws.services.sqs.model.Message message, Map<String, Object> additionalHeaders) {
  2.   HashMap<String, Object> messageHeaders = new HashMap<>();
  3.   messageHeaders.put(MESSAGE_ID_MESSAGE_ATTRIBUTE_NAME, message.getMessageId());
  4.   messageHeaders.put(RECEIPT_HANDLE_MESSAGE_ATTRIBUTE_NAME, message.getReceiptHandle());
  5.   messageHeaders.putAll(additionalHeaders);
  6.   messageHeaders.putAll(getAttributesAsMessageHeaders(message));
  7.   messageHeaders.putAll(getMessageAttributesAsMessageHeaders(message));
  8.   return new GenericMessage<>(message.getBody(), new SqsMessageHeaders(messageHeaders));
  9. }

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

  1. public static Message<String> createMessage(com.amazonaws.services.sqs.model.Message message, Map<String, Object> additionalHeaders) {
  2.   HashMap<String, Object> messageHeaders = new HashMap<>();
  3.   messageHeaders.put(MESSAGE_ID_MESSAGE_ATTRIBUTE_NAME, message.getMessageId());
  4.   messageHeaders.put(RECEIPT_HANDLE_MESSAGE_ATTRIBUTE_NAME, message.getReceiptHandle());
  5.   messageHeaders.putAll(additionalHeaders);
  6.   messageHeaders.putAll(getAttributesAsMessageHeaders(message));
  7.   messageHeaders.putAll(getMessageAttributesAsMessageHeaders(message));
  8.   return new GenericMessage<>(message.getBody(), new SqsMessageHeaders(messageHeaders));
  9. }

代码示例来源：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: 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: Comcast/cmb

  1. public CQSMessage(Message message) {
  2.   
  3.   this.messageId = message.getMessageId();
  4.   this.receiptHandle = message.getReceiptHandle();
  5.   this.body = message.getBody();
  6.   this.mD5OfBody = message.getMD5OfBody();
  7.   
  8.   this.messageAttributes = new HashMap<String, CQSMessageAttribute>();
  9.   
  10.   for (String messageAttributeName : message.getMessageAttributes().keySet()) {
  11.     MessageAttributeValue messageAttributeValue = message.getMessageAttributes().get(messageAttributeName);
  12.     CQSMessageAttribute ma = new CQSMessageAttribute(messageAttributeValue.getStringValue(), messageAttributeValue.getDataType());
  13.     this.messageAttributes.put(messageAttributeName, ma);
  14.   }
  15.   
  16.   this.md5OfMessageAttributes = message.getMD5OfMessageAttributes();
  17. }

代码示例来源：origin: com.netflix.spinnaker.echo/echo-pubsub-aws

  1. @Override
  2. public void ack() {
  3.  // Delete from queue
  4.  try {
  5.   amazonSQS.deleteMessage(queueUrl, message.getReceiptHandle());
  6.   registry.counter(getProcessedMetricId(subscriptionName)).increment();
  7.  } catch (ReceiptHandleIsInvalidException e) {
  8.   log.warn(
  9.    "Error deleting message: {}, queue: {}, reason: {} (receiptHandle: {})",
  10.    message.getMessageId(),
  11.    queueUrl,
  12.    e.getMessage(),
  13.    message.getReceiptHandle()
  14.   );
  15.  }
  16. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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