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

ReceiveMessageRequest.setQueueUrl介绍

[英]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

/**
 * Constructs a new ReceiveMessageRequest object. Callers should use the setter or fluent setter (with...) methods
 * to initialize any additional object members.
 * 
 * @param queueUrl
 *        The URL of the Amazon SQS queue from which messages are received.</p>
 *        <p>
 *        Queue URLs and names are case-sensitive.
 */
public ReceiveMessageRequest(String queueUrl) {
  setQueueUrl(queueUrl);
}

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

/**
 * <p>
 * The URL of the Amazon SQS queue from which messages are received.
 * </p>
 * <p>
 * Queue URLs and names are case-sensitive.
 * </p>
 * 
 * @param queueUrl
 *        The URL of the Amazon SQS queue from which messages are received.</p>
 *        <p>
 *        Queue URLs and names are case-sensitive.
 * @return Returns a reference to this object so that method calls can be chained together.
 */
public ReceiveMessageRequest withQueueUrl(String queueUrl) {
  setQueueUrl(queueUrl);
  return this;
}

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

request.setMaxNumberOfMessages(context.getProperty(BATCH_SIZE).asInteger());
request.setVisibilityTimeout(context.getProperty(VISIBILITY_TIMEOUT).asTimePeriod(TimeUnit.SECONDS).intValue());
request.setQueueUrl(queueUrl);
request.setWaitTimeSeconds(context.getProperty(RECEIVE_MSG_WAIT_TIME).asTimePeriod(TimeUnit.SECONDS).intValue());

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

/**
 * Constructs a new ReceiveMessageRequest object. Callers should use the
 * setter or fluent setter (with...) methods to initialize any additional
 * object members.
 * 
 * @param queueUrl <p>
 *            The URL of the Amazon SQS queue to take action on.
 *            </p>
 *            <p>
 *            Queue URLs are case-sensitive.
 *            </p>
 */
public ReceiveMessageRequest(String queueUrl) {
  setQueueUrl(queueUrl);
}

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

throws AmazonServiceException, AmazonClientException {
ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest();
receiveMessageRequest.setQueueUrl(queueUrl);
return receiveMessage(receiveMessageRequest);

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

/**
 * Constructs a new ReceiveMessageRequest object. Callers should use the setter or fluent setter (with...) methods
 * to initialize any additional object members.
 * 
 * @param queueUrl
 *        The URL of the Amazon SQS queue from which messages are received.</p>
 *        <p>
 *        Queue URLs and names are case-sensitive.
 */
public ReceiveMessageRequest(String queueUrl) {
  setQueueUrl(queueUrl);
}

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

/**
 * Constructs a new ReceiveMessageRequest object. Callers should use the
 * setter or fluent setter (with...) methods to initialize any additional
 * object members.
 * 
 * @param queueUrl <p>
 *            The URL of the Amazon SQS queue to take action on.
 *            </p>
 *            <p>
 *            Queue URLs are case-sensitive.
 *            </p>
 */
public ReceiveMessageRequest(String queueUrl) {
  setQueueUrl(queueUrl);
}

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

/**
 * <p>
 * The URL of the Amazon SQS queue from which messages are received.
 * </p>
 * <p>
 * Queue URLs and names are case-sensitive.
 * </p>
 * 
 * @param queueUrl
 *        The URL of the Amazon SQS queue from which messages are received.</p>
 *        <p>
 *        Queue URLs and names are case-sensitive.
 * @return Returns a reference to this object so that method calls can be chained together.
 */
public ReceiveMessageRequest withQueueUrl(String queueUrl) {
  setQueueUrl(queueUrl);
  return this;
}

代码示例来源：origin: io.macgyver.rx-aws/rx-aws

@Override
public void run() {
  while (isRunning()) {
    try {
      ReceiveMessageRequest request = new ReceiveMessageRequest();
      request.setQueueUrl(getQueueUrl());
      request.setAttributeNames(ImmutableList.of("ALL"));
      request.setWaitTimeSeconds(waitTimeSeconds);
      Future<ReceiveMessageResult> result = client.receiveMessageAsync(request, new Handler());
      result.get(); // go ahead and block
    } catch (Exception e) {
      logger.warn("", e);
      failureCount.incrementAndGet();
    }
    try {
      long rescheduleDelay = Math.min(60000, 1000 * failureCount.get() * 3);
      if (rescheduleDelay > 0) {
        logger.info("pausing for {}ms due to errors", rescheduleDelay);
        Thread.sleep(rescheduleDelay);
      }
    } catch (InterruptedException e) {
      // swallow it
    }
  }
}

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

throws AmazonServiceException, AmazonClientException {
ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest();
receiveMessageRequest.setQueueUrl(queueUrl);
return receiveMessage(receiveMessageRequest);

代码示例来源：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.setQueueUrl(this.tocQueueUrl);

代码示例来源：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.setMaxNumberOfMessages(context.getProperty(BATCH_SIZE).asInteger());
request.setVisibilityTimeout(context.getProperty(VISIBILITY_TIMEOUT).asTimePeriod(TimeUnit.SECONDS).intValue());
request.setQueueUrl(queueUrl);
request.setWaitTimeSeconds(context.getProperty(RECEIVE_MSG_WAIT_TIME).asTimePeriod(TimeUnit.SECONDS).intValue());