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

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

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

Message.getReceiptHandle介绍

[英]An identifier associated with the act of receiving the message. A new receipt handle is returned every time you receive a message. When deleting a message, you provide the last received receipt handle to delete the message.
[中]与接收信息的行为相关联的标识符。每次收到消息时，都会返回一个新的接收句柄。删除邮件时，提供上次收到的回执句柄以删除邮件。

代码示例

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

  1. private void deleteMessage(Message message) {
  2.   try {
  3.     sqs.deleteMessage(new DeleteMessageRequest(queueUrl, message.getReceiptHandle()));
  4.   } catch (Exception e) {}
  5. }

代码示例来源：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: awsdocs/aws-doc-sdk-examples

  1. public static void changeMessageVisibilitySingle(
  2.     String queue_url, int timeout)
  3. {
  4.   AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
  5.   // Get the receipt handle for the first message in the queue.
  6.   String receipt = sqs.receiveMessage(queue_url)
  7.             .getMessages()
  8.             .get(0)
  9.             .getReceiptHandle();
  10.   sqs.changeMessageVisibility(queue_url, receipt, timeout);
  11. }

代码示例来源：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: awsdocs/aws-doc-sdk-examples

  1. public static void changeMessageVisibilityMultiple(
  2.     String queue_url, int timeout)
  3. {
  4.   AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();
  5.   List<ChangeMessageVisibilityBatchRequestEntry> entries =
  6.     new ArrayList<ChangeMessageVisibilityBatchRequestEntry>();
  7.   entries.add(new ChangeMessageVisibilityBatchRequestEntry(
  8.         "unique_id_msg1",
  9.         sqs.receiveMessage(queue_url)
  10.           .getMessages()
  11.           .get(0)
  12.           .getReceiptHandle())
  13.       .withVisibilityTimeout(timeout));
  14.   entries.add(new ChangeMessageVisibilityBatchRequestEntry(
  15.         "unique_id_msg2",
  16.         sqs.receiveMessage(queue_url)
  17.           .getMessages()
  18.           .get(0)
  19.           .getReceiptHandle())
  20.       .withVisibilityTimeout(timeout + 200));
  21.   sqs.changeMessageVisibilityBatch(queue_url, entries);
  22. }

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

  1. /**
  2.  * Nacks and clears all messages remaining in the batch.
  3.  */
  4. synchronized void clear() {
  5.   if (!open) {
  6.     throw new IllegalStateException("batch is not open");
  7.   }
  8.   if (!isExpired()) {
  9.     ChangeMessageVisibilityBatchRequest batchRequest = new ChangeMessageVisibilityBatchRequest()
  10.         .withQueueUrl(qUrl);
  11.     ResultConverter.appendUserAgent(batchRequest, AmazonSQSBufferedAsyncClient.USER_AGENT);
  12.     List<ChangeMessageVisibilityBatchRequestEntry> entries = new ArrayList<ChangeMessageVisibilityBatchRequestEntry>(
  13.         messages.size());
  14.     int i = 0;
  15.     for (Message m : messages) {
  16.       entries.add(new ChangeMessageVisibilityBatchRequestEntry().withId(Integer.toString(i))
  17.           .withReceiptHandle(m.getReceiptHandle()).withVisibilityTimeout(0));
  18.       ++i;
  19.     }
  20.     try {
  21.       batchRequest.setEntries(entries);
  22.       sqsClient.changeMessageVisibilityBatch(batchRequest);
  23.     } catch (AmazonClientException e) {
  24.       // Log and ignore.
  25.       log.warn("ReceiveMessageBatchTask: changeMessageVisibility failed " + e);
  26.     }
  27.   }
  28.   messages.clear();
  29. }

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

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

  1. attributes.put("hash.algorithm", "md5");
  2. attributes.put("sqs.message.id", message.getMessageId());
  3. attributes.put("sqs.receipt.handle", message.getReceiptHandle());
  4.   final DeleteMessageBatchRequestEntry entry = new DeleteMessageBatchRequestEntry();
  5.   entry.setId(message.getMessageId());
  6.   entry.setReceiptHandle(message.getReceiptHandle());
  7.   deleteRequestEntries.add(entry);

代码示例来源：origin: awsdocs/aws-doc-sdk-examples

  1. sqs.deleteMessage(queueUrl, m.getReceiptHandle());

代码示例来源：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. .withReceiptHandle(m.getReceiptHandle())
  2.     .withVisibilityTimeout(0));
  3. ++i;

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

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

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

  1. request.addParameter(prefix, StringUtils.fromString(messageId));
  2. if (_message.getReceiptHandle() != null) {
  3.   prefix = _prefix + "ReceiptHandle";
  4.   String receiptHandle = _message.getReceiptHandle();
  5.   request.addParameter(prefix, StringUtils.fromString(receiptHandle));

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

  1. private org.springframework.messaging.Message<String> getMessageForExecution() {
  2.     HashMap<String, Object> additionalHeaders = new HashMap<>();
  3.     additionalHeaders.put(QueueMessageHandler.LOGICAL_RESOURCE_ID, this.logicalQueueName);
  4.     if (this.deletionPolicy == SqsMessageDeletionPolicy.NEVER) {
  5.       String receiptHandle = this.message.getReceiptHandle();
  6.       QueueMessageAcknowledgment acknowledgment = new QueueMessageAcknowledgment(SimpleMessageListenerContainer.this.getAmazonSqs(), this.queueUrl, receiptHandle);
  7.       additionalHeaders.put(QueueMessageHandler.ACKNOWLEDGMENT, acknowledgment);
  8.     }
  9.     additionalHeaders.put(QueueMessageHandler.VISIBILITY, new QueueMessageVisibility(SimpleMessageListenerContainer.this.getAmazonSqs(), this.queueUrl, this.message.getReceiptHandle()));
  10.     return createMessage(this.message, additionalHeaders);
  11.   }
  12. }

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

  1. private void deleteMessage(Message message) {
  2.   try {
  3.     sqs.deleteMessage(new DeleteMessageRequest(queueUrl, message.getReceiptHandle()));
  4.   } catch (Exception e) {}
  5. }

代码示例来源：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.apache.beam/beam-sdks-java-io-amazon-web-services

  1. void delete(final Collection<Message> messages) {
  2.  for (Message message : messages) {
  3.   if (messagesToDelete.contains(message)) {
  4.    source.getSqs().deleteMessage(source.getRead().queueUrl(), message.getReceiptHandle());
  5.    Instant currentMessageTimestamp = getTimestamp(message);
  6.    if (currentMessageTimestamp.isAfter(oldestPendingTimestamp)) {
  7.     oldestPendingTimestamp = currentMessageTimestamp;
  8.    }
  9.   }
  10.  }
  11. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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