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

ReceiveMessageRequest.<init>介绍

[英]Default constructor for ReceiveMessageRequest object. Callers should use the setter or fluent setter (with...) methods to initialize the object after creating it.
[中]ReceiveMessageRequest对象的默认构造函数。呼叫者应使用setter或fluent setter（带…）方法在创建对象后初始化该对象。

代码示例

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

@Override
public Future<ReceiveMessageResult> receiveMessageAsync(
    String queueUrl,
    AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler) {
  return receiveMessageAsync(new ReceiveMessageRequest(queueUrl), asyncHandler);
}

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

@Override
public ReceiveMessageResult receiveMessage(String queueUrl) throws AmazonServiceException, AmazonClientException {
  return receiveMessage(new ReceiveMessageRequest(queueUrl));
}

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

@Override
public Future<ReceiveMessageResult> receiveMessageAsync(String queueUrl) {
  return receiveMessageAsync(new ReceiveMessageRequest(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

/**
 * 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

@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: aws/aws-sdk-java

List<Message> messages = sqs.receiveMessage(new ReceiveMessageRequest(queueUrl)).getMessages();
for (Message message : messages) {
  String messageBody = message.getBody();

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

ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest( url );
receiveMessageRequest.setAttributeNames(requestMessageAttributeNames);
receiveMessageRequest.setMaxNumberOfMessages( limit );

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

/**
   * Attempts to retrieve messages from SQS and upon completion (successful or unsuccessful)
   * reports the batch as complete and open
   */
  public void run() {
    try {
      visibilityDeadlineNano = System.nanoTime() + visibilityTimeoutNanos;
      ReceiveMessageRequest request = new ReceiveMessageRequest(qUrl).withMaxNumberOfMessages(config
          .getMaxBatchSize());
      ResultConverter.appendUserAgent(request, AmazonSQSBufferedAsyncClient.USER_AGENT);
      if (config.getVisibilityTimeoutSeconds() > 0) {
        request.setVisibilityTimeout(config.getVisibilityTimeoutSeconds());
        visibilityDeadlineNano = System.nanoTime()
            + TimeUnit.NANOSECONDS.convert(config.getVisibilityTimeoutSeconds(), TimeUnit.SECONDS);
      }
      if (config.isLongPoll()) {
        request.withWaitTimeSeconds(config.getLongPollWaitTimeoutSeconds());
      }
      messages = sqsClient.receiveMessage(request).getMessages();
    } catch (AmazonClientException e) {
      exception = e;
    } finally {
      // whatever happened, we are done and can be considered open
      open = true;
      parentBuffer.reportBatchFinished(this);
    }
  }
}

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

ReceiveMessageRequest receive_request = new ReceiveMessageRequest()
    .withQueueUrl(queue_url)
    .withWaitTimeSeconds(20);

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

final ReceiveMessageRequest request = new ReceiveMessageRequest();
request.setAttributeNames(Collections.singleton("All"));
request.setMessageAttributeNames(Collections.singleton("All"));

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

@Override
public ReceiveMessageResult receiveMessage(String queueUrl)
    throws AmazonServiceException, AmazonClientException {
  return receiveMessage(new ReceiveMessageRequest(queueUrl));
}

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

ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest();
receiveMessageRequest.setQueueUrl(queueUrl);
return receiveMessage(receiveMessageRequest);

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

/**
   * Attempts to retrieve messages from SQS and upon completion
   * (successful or unsuccessful) reports the batch as complete and open
   */
  @Override
  public void run() {
    try {
      visibilityDeadlineNano = System.nanoTime() + visibilityTimeoutNanos;
      ReceiveMessageRequest request = new ReceiveMessageRequest(qUrl)
          .withMaxNumberOfMessages(config.getMaxBatchSize());
      ResultConverter.appendUserAgent(request, AmazonSQSBufferedAsyncClient.USER_AGENT);
      if (config.getVisibilityTimeoutSeconds() > 0) {
        request.setVisibilityTimeout(config.getVisibilityTimeoutSeconds());
        visibilityDeadlineNano = System.nanoTime()
            + TimeUnit.NANOSECONDS.convert(config.getVisibilityTimeoutSeconds(),
                TimeUnit.SECONDS);
      }
      if (config.isLongPoll()) {
        request.withWaitTimeSeconds(config.getLongPollWaitTimeoutSeconds());
      }
      messages = sqsClient.receiveMessage(request).getMessages();
    } catch (AmazonClientException e) {
      exception = e;
    } finally {
      // whatever happened, we are done and can be considered open
      open = true;
      parentBuffer.reportBatchFinished(this);
    }
  }
}

代码示例来源：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));
}