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

ReceiveMessageRequest.setMaxNumberOfMessages介绍

[英]The maximum number of messages to return. Amazon SQS never returns more messages than this value (however, fewer messages might be returned). Valid values: 1 to 10. Default: 1.
[中]要返回的最大消息数。Amazon SQS不会返回超过此值的消息（但是，返回的消息可能会更少）。有效值：1到10。默认值：1。

代码示例

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

/**
 * <p>
 * The maximum number of messages to return. Amazon SQS never returns more messages than this value (however, fewer
 * messages might be returned). Valid values: 1 to 10. Default: 1.
 * </p>
 * 
 * @param maxNumberOfMessages
 *        The maximum number of messages to return. Amazon SQS never returns more messages than this value (however,
 *        fewer messages might be returned). Valid values: 1 to 10. Default: 1.
 * @return Returns a reference to this object so that method calls can be chained together.
 */
public ReceiveMessageRequest withMaxNumberOfMessages(Integer maxNumberOfMessages) {
  setMaxNumberOfMessages(maxNumberOfMessages);
  return this;
}

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

receiveMessageRequest.setMaxNumberOfMessages( limit );
receiveMessageRequest.setVisibilityTimeout(
  Math.max( MIN_VISIBILITY_TIMEOUT, fig.getVisibilityTimeout() / 1000 ) );

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

request.setAttributeNames(Collections.singleton("All"));
request.setMessageAttributeNames(Collections.singleton("All"));
request.setMaxNumberOfMessages(context.getProperty(BATCH_SIZE).asInteger());
request.setVisibilityTimeout(context.getProperty(VISIBILITY_TIMEOUT).asTimePeriod(TimeUnit.SECONDS).intValue());
request.setQueueUrl(queueUrl);

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

/**
 * <p>
 * The maximum number of messages to return. Amazon SQS never returns more messages than this value (however, fewer
 * messages might be returned). Valid values: 1 to 10. Default: 1.
 * </p>
 * 
 * @param maxNumberOfMessages
 *        The maximum number of messages to return. Amazon SQS never returns more messages than this value (however,
 *        fewer messages might be returned). Valid values: 1 to 10. Default: 1.
 * @return Returns a reference to this object so that method calls can be chained together.
 */
public ReceiveMessageRequest withMaxNumberOfMessages(Integer maxNumberOfMessages) {
  setMaxNumberOfMessages(maxNumberOfMessages);
  return this;
}

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

try {
  ReceiveMessageRequest rmr = new ReceiveMessageRequest(spec.getQueueURL());
  rmr.setMaxNumberOfMessages(spec.getMaxMessages());
  rmr.setVisibilityTimeout(spec.getVisibilityTimeout());
  rmr.setWaitTimeSeconds(spec.getPollInterval()/1000);

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

private void pull() {
 final ReceiveMessageRequest receiveMessageRequest =
   new ReceiveMessageRequest(source.getRead().queueUrl());
 receiveMessageRequest.setMaxNumberOfMessages(MAX_NUMBER_OF_MESSAGES);
 receiveMessageRequest.setAttributeNames(
   Arrays.asList(MessageSystemAttributeName.SentTimestamp.toString()));
 final ReceiveMessageResult receiveMessageResult =
   source.getSqs().receiveMessage(receiveMessageRequest);
 final List<Message> messages = receiveMessageResult.getMessages();
 if (messages == null || messages.isEmpty()) {
  return;
 }
 for (Message message : messages) {
  messagesNotYetRead.add(message);
 }
}

代码示例来源：origin: stackoverflow.com

receiveMessageRequest.setMaxNumberOfMessages(number_of_message_);
receiveMessageRequest.withMaxNumberOfMessages(number_of_message_).withWaitTimeSeconds(wait_time_second_);
List<Message> messages = sqs.receiveMessage(receiveMessageRequest).getMessages();

代码示例来源：origin: Comcast/cmb

receiveMessageRequest.setMaxNumberOfMessages(maxNumberOfMessages);
receiveMessageRequest.setMessageAttributeNames(new ArrayList<String>(Arrays.asList("All")));

代码示例来源：origin: bitsofinfo/s3-bucket-loader

req.setMaxNumberOfMessages(10);
req.setVisibilityTimeout(300);
req.setQueueUrl(sqsQueueUrl);

代码示例来源：origin: bitsofinfo/s3-bucket-loader

req.setQueueUrl(this.tocQueueUrl);
req.setVisibilityTimeout(900); // 15 minutes it will be invisible to other consumers
req.setMaxNumberOfMessages(10);

代码示例来源：origin: bitsofinfo/s3-bucket-loader

req.setMaxNumberOfMessages(1); // only one at a time..

代码示例来源：origin: com.erudika/para

@Override
public String pull() {
  String task = "[]";
  if (!StringUtils.isBlank(url)) {
    try {
      ReceiveMessageRequest receiveReq = new ReceiveMessageRequest(url);
      receiveReq.setMaxNumberOfMessages(MAX_MESSAGES);
      List<Message> list = client().receiveMessage(receiveReq).getMessages();
      if (list != null && !list.isEmpty()) {
        Message message = list.get(0);
        client().deleteMessage(new DeleteMessageRequest(url, message.getReceiptHandle()));
        task = message.getBody();
      }
    } catch (AmazonServiceException ase) {
      logException(ase);
    } catch (AmazonClientException ace) {
      logger.error("Could not reach SQS. {}", ace.toString());
    }
  }
  return task;
}

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

/**
 * Poll SQS queue for incoming messages, filter them, and return a list of SQS Messages.
 *
 * @return a list of SQS messages.
 */
public List<Message> pollQueue() {
  boolean success = false;
  ProgressStatus pollQueueStatus = new ProgressStatus(ProgressState.pollQueue, new BasicPollQueueInfo(0, success));
  final Object reportObject = progressReporter.reportStart(pollQueueStatus);
  ReceiveMessageRequest request = new ReceiveMessageRequest().withAttributeNames(ALL_ATTRIBUTES);
  request.setQueueUrl(config.getSqsUrl());
  request.setVisibilityTimeout(config.getVisibilityTimeout());
  request.setMaxNumberOfMessages(DEFAULT_SQS_MESSAGE_SIZE_LIMIT);
  request.setWaitTimeSeconds(DEFAULT_WAIT_TIME_SECONDS);
  List<Message> sqsMessages = new ArrayList<Message>();
  try {
    ReceiveMessageResult result = sqsClient.receiveMessage(request);
    sqsMessages = result.getMessages();
    logger.info("Polled " + sqsMessages.size() + " sqs messages from " + config.getSqsUrl());
    success = true;
  } catch (AmazonServiceException e) {
    LibraryUtils.handleException(exceptionHandler, pollQueueStatus, e, "Failed to poll sqs message.");
  } finally {
    LibraryUtils.endToProcess(progressReporter, success, pollQueueStatus, reportObject);
  }
  return sqsMessages;
}

代码示例来源：origin: org.apache.nifi/nifi-aws-processors

request.setAttributeNames(Collections.singleton("All"));
request.setMessageAttributeNames(Collections.singleton("All"));
request.setMaxNumberOfMessages(context.getProperty(BATCH_SIZE).asInteger());
request.setVisibilityTimeout(context.getProperty(VISIBILITY_TIMEOUT).asTimePeriod(TimeUnit.SECONDS).intValue());
request.setQueueUrl(queueUrl);