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

x33g5p2x  于2022-01-29 转载在 其他  
字(9.0k)|赞(0)|评价(0)|浏览(97)

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

ReceiveMessageRequest.withQueueUrl介绍

[英]The URL of the Amazon SQS queue from which messages are received.

Queue URLs and names are case-sensitive.
[中]接收消息的Amazon SQS队列的URL。
队列URL和名称区分大小写。

代码示例

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

/**
 * Simplified method form for invoking the ReceiveMessage operation with an AsyncHandler.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest, com.amazonaws.handlers.AsyncHandler)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl,
    com.amazonaws.handlers.AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl), asyncHandler);
}

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

/**
 * Simplified method form for invoking the ReceiveMessage operation.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

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

/**
 * Simplified method form for invoking the ReceiveMessage operation with an AsyncHandler.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest, com.amazonaws.handlers.AsyncHandler)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl,
    com.amazonaws.handlers.AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl), asyncHandler);
}

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

/**
 * Simplified method form for invoking the ReceiveMessage operation.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

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

@Override
public ReceiveMessageResult receiveMessage(String queueUrl) {
  return receiveMessage(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

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

@Override
public ReceiveMessageResult receiveMessage(String queueUrl) {
  return receiveMessage(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

代码示例来源：origin: Netflix/conductor

@VisibleForTesting
List<Message> receiveMessages() {
  try {
    ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest()
        .withQueueUrl(queueURL)
        .withVisibilityTimeout(visibilityTimeoutInSeconds)
        .withMaxNumberOfMessages(batchSize);
    ReceiveMessageResult result = client.receiveMessage(receiveMessageRequest);
    List<Message> messages = result.getMessages().stream()
        .map(msg -> new Message(msg.getMessageId(), msg.getBody(), msg.getReceiptHandle()))
        .collect(Collectors.toList());
    Monitors.recordEventQueueMessagesProcessed(QUEUE_TYPE, this.queueName, messages.size());
    return messages;
  } catch (Exception e) {
    logger.error("Exception while getting messages from SQS", e);
    Monitors.recordObservableQMessageReceivedErrors(QUEUE_TYPE);
  }
  return new ArrayList<>();
}

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

.withQueueUrl(queue_url)
    .withWaitTimeSeconds(20);
sqs.receiveMessage(receive_request);

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

/**
 * Simplified method form for invoking the ReceiveMessage operation.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

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

/**
 * Simplified method form for invoking the ReceiveMessage operation with an AsyncHandler.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest, com.amazonaws.handlers.AsyncHandler)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl,
    com.amazonaws.handlers.AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl), asyncHandler);
}

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

/**
 * Simplified method form for invoking the ReceiveMessage operation.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

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

/**
 * Simplified method form for invoking the ReceiveMessage operation with an AsyncHandler.
 *
 * @see #receiveMessageAsync(ReceiveMessageRequest, com.amazonaws.handlers.AsyncHandler)
 */
@Override
public java.util.concurrent.Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl,
    com.amazonaws.handlers.AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler) {
  return receiveMessageAsync(new ReceiveMessageRequest().withQueueUrl(queueUrl), asyncHandler);
}

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

@Override
public ReceiveMessageResult receiveMessage(String queueUrl) {
  return receiveMessage(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

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

@Override
public ReceiveMessageResult receiveMessage(String queueUrl) {
  return receiveMessage(new ReceiveMessageRequest().withQueueUrl(queueUrl));
}

代码示例来源：origin: com.hotels/shunting-yard-receiver-sqs

private void readRecordsIfNeeded() {
 while (records == null || !records.hasNext()) {
  ReceiveMessageRequest request = new ReceiveMessageRequest()
    .withQueueUrl(queueUrl)
    .withWaitTimeSeconds(waitTimeSeconds);
  records = consumer.receiveMessage(request).getMessages().iterator();
 }
}

代码示例来源：origin: bazaarvoice/emodb

@Override
public List<ScanRangeTask> claimScanRangeTasks(int max, Duration ttl) {
  if (max == 0) {
    return ImmutableList.of();
  }
  List<Message> messages = _sqs.receiveMessage(new ReceiveMessageRequest()
      .withQueueUrl(getQueueUrl(_pendingScanRangeQueue))
      .withMaxNumberOfMessages(Math.min(max, 10))           // SQS cannot claim more than 10 messages
      .withVisibilityTimeout(toSeconds(ttl))
  ).getMessages();
  return FluentIterable.from(messages)
      .transform(new Function<Message, ScanRangeTask>() {
        @Override
        public ScanRangeTask apply(Message message) {
          QueueScanRangeTask task = JsonHelper.fromJson(message.getBody(), QueueScanRangeTask.class);
          task.setMessageId(message.getReceiptHandle());
          return task;
        }
      })
      .toList();
}

代码示例来源：origin: com.netflix.conductor/conductor-contribs

@VisibleForTesting
List<Message> receiveMessages() {
  try {
    ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest()
        .withQueueUrl(queueURL)
        .withVisibilityTimeout(visibilityTimeoutInSeconds)
        .withMaxNumberOfMessages(batchSize);
    ReceiveMessageResult result = client.receiveMessage(receiveMessageRequest);
    List<Message> messages = result.getMessages().stream()
        .map(msg -> new Message(msg.getMessageId(), msg.getBody(), msg.getReceiptHandle()))
        .collect(Collectors.toList());
    Monitors.recordEventQueueMessagesProcessed(QUEUE_TYPE, this.queueName, messages.size());
    return messages;
  } catch (Exception e) {
    logger.error("Exception while getting messages from SQS", e);
    Monitors.recordObservableQMessageReceivedErrors(QUEUE_TYPE);
  }
  return new ArrayList<>();
}

代码示例来源：origin: com.netflix.suro/suro-server

@Override
public String recv() {
  ReceiveMessageRequest request = new ReceiveMessageRequest()
      .withQueueUrl(queueUrls.get(0))
      .withMaxNumberOfMessages(1);
  try {
    ReceiveMessageResult result = sqsClient.receiveMessage(request);
    if (!result.getMessages().isEmpty()) {
      Message msg = result.getMessages().get(0);
      recvMessageCount.incrementAndGet();
      DeleteMessageRequest deleteReq = new DeleteMessageRequest()
          .withQueueUrl(queueUrls.get(0))
          .withReceiptHandle(msg.getReceiptHandle());
      sqsClient.deleteMessage(deleteReq);
      if (enableBase64Encoding) {
        return new String(
            Base64.decodeBase64(msg.getBody().getBytes()),
            Charsets.UTF_8);
      } else {
        return msg.getBody();
      }
    } else {
      return "";
    }
  } catch (Exception e) {
    log.error("Exception while recving SQS notice: " + e.getMessage(), e);
    return "";
  }
}

代码示例来源：origin: bazaarvoice/emodb

@Override
public List<ScanRangeComplete> claimCompleteScanRanges(Duration ttl) {
  List<Message> messages = _sqs.receiveMessage(new ReceiveMessageRequest()
      .withQueueUrl(getQueueUrl(_completeScanRangeQueue))
      .withMaxNumberOfMessages(10)
      .withVisibilityTimeout(toSeconds(ttl))
  ).getMessages();
  return FluentIterable.from(messages)
      .transform(new Function<Message, ScanRangeComplete>() {
        @Override
        public ScanRangeComplete apply(Message message) {
          QueueScanRangeComplete completion = JsonHelper.fromJson(message.getBody(), QueueScanRangeComplete.class);
          completion.setMessageId(message.getReceiptHandle());
          return completion;
        }
      })
      .toList();
}

代码示例来源：origin: classmethod/gradle-aws-plugin

ReceiveMessageRequest request = new ReceiveMessageRequest().withQueueUrl(queueUrl)
  .withMaxNumberOfMessages(MAX_MESSAGE_CONSUME_BATCH_SIZE).withVisibilityTimeout(30);
List<DeleteMessageBatchRequestEntry> messagesToDelete =

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

ReceiveMessageRequest

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    ReceiveMessageRequest类方法

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