本文整理了Java中com.amazonaws.services.sqs.model.ReceiveMessageRequest.getQueueUrl
方法的一些代码示例,展示了ReceiveMessageRequest.getQueueUrl
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ReceiveMessageRequest.getQueueUrl
方法的具体详情如下:
包路径:com.amazonaws.services.sqs.model.ReceiveMessageRequest
类名称:ReceiveMessageRequest
方法名:getQueueUrl
[英]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
/**
* Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be
* redacted from this string using a placeholder value.
*
* @return A string representation of this object.
*
* @see java.lang.Object#toString()
*/
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("{");
if (getQueueUrl() != null)
sb.append("QueueUrl: ").append(getQueueUrl()).append(",");
if (getAttributeNames() != null)
sb.append("AttributeNames: ").append(getAttributeNames()).append(",");
if (getMessageAttributeNames() != null)
sb.append("MessageAttributeNames: ").append(getMessageAttributeNames()).append(",");
if (getMaxNumberOfMessages() != null)
sb.append("MaxNumberOfMessages: ").append(getMaxNumberOfMessages()).append(",");
if (getVisibilityTimeout() != null)
sb.append("VisibilityTimeout: ").append(getVisibilityTimeout()).append(",");
if (getWaitTimeSeconds() != null)
sb.append("WaitTimeSeconds: ").append(getWaitTimeSeconds()).append(",");
if (getReceiveRequestAttemptId() != null)
sb.append("ReceiveRequestAttemptId: ").append(getReceiveRequestAttemptId());
sb.append("}");
return sb.toString();
}
代码示例来源:origin: aws/aws-sdk-java
public Future<ReceiveMessageResult> receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessage(receiveMessageRequest, asyncHandler);
}
代码示例来源:origin: aws/aws-sdk-java
@Override
public int hashCode() {
final int prime = 31;
int hashCode = 1;
hashCode = prime * hashCode + ((getQueueUrl() == null) ? 0 : getQueueUrl().hashCode());
hashCode = prime * hashCode + ((getAttributeNames() == null) ? 0 : getAttributeNames().hashCode());
hashCode = prime * hashCode + ((getMessageAttributeNames() == null) ? 0 : getMessageAttributeNames().hashCode());
hashCode = prime * hashCode + ((getMaxNumberOfMessages() == null) ? 0 : getMaxNumberOfMessages().hashCode());
hashCode = prime * hashCode + ((getVisibilityTimeout() == null) ? 0 : getVisibilityTimeout().hashCode());
hashCode = prime * hashCode + ((getWaitTimeSeconds() == null) ? 0 : getWaitTimeSeconds().hashCode());
hashCode = prime * hashCode + ((getReceiveRequestAttemptId() == null) ? 0 : getReceiveRequestAttemptId().hashCode());
return hashCode;
}
代码示例来源:origin: aws/aws-sdk-java
public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageRequest)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessageSync(receiveMessageRequest);
}
代码示例来源:origin: aws/aws-sdk-java
public Future<ReceiveMessageResult> receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessage(receiveMessageRequest, null);
}
代码示例来源:origin: aws/aws-sdk-java
return false;
ReceiveMessageRequest other = (ReceiveMessageRequest) obj;
if (other.getQueueUrl() == null ^ this.getQueueUrl() == null)
return false;
if (other.getQueueUrl() != null && other.getQueueUrl().equals(this.getQueueUrl()) == false)
return false;
if (other.getAttributeNames() == null ^ this.getAttributeNames() == null)
代码示例来源:origin: aws/aws-sdk-java
request.setHttpMethod(HttpMethodName.POST);
if (receiveMessageRequest.getQueueUrl() != null) {
request.addParameter("QueueUrl", StringUtils.fromString(receiveMessageRequest.getQueueUrl()));
代码示例来源:origin: aws-amplify/aws-sdk-android
@Override
public Future<ReceiveMessageResult> receiveMessageAsync(
ReceiveMessageRequest receiveMessageRequest)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessage(receiveMessageRequest, null);
}
代码示例来源:origin: aws-amplify/aws-sdk-android
@Override
public ReceiveMessageResult receiveMessage(
ReceiveMessageRequest receiveMessageRequest)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessageSync(receiveMessageRequest);
}
代码示例来源:origin: aws-amplify/aws-sdk-android
@Override
public Future<ReceiveMessageResult> receiveMessageAsync(
ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessage(receiveMessageRequest, asyncHandler);
}
代码示例来源:origin: aws-amplify/aws-sdk-android
/**
* Returns a string representation of this object; useful for testing and
* debugging.
*
* @return A string representation of this object.
* @see java.lang.Object#toString()
*/
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("{");
if (getQueueUrl() != null)
sb.append("QueueUrl: " + getQueueUrl() + ",");
if (getAttributeNames() != null)
sb.append("AttributeNames: " + getAttributeNames() + ",");
if (getMessageAttributeNames() != null)
sb.append("MessageAttributeNames: " + getMessageAttributeNames() + ",");
if (getMaxNumberOfMessages() != null)
sb.append("MaxNumberOfMessages: " + getMaxNumberOfMessages() + ",");
if (getVisibilityTimeout() != null)
sb.append("VisibilityTimeout: " + getVisibilityTimeout() + ",");
if (getWaitTimeSeconds() != null)
sb.append("WaitTimeSeconds: " + getWaitTimeSeconds() + ",");
if (getReceiveRequestAttemptId() != null)
sb.append("ReceiveRequestAttemptId: " + getReceiveRequestAttemptId());
sb.append("}");
return sb.toString();
}
代码示例来源:origin: aws-amplify/aws-sdk-android
@Override
public int hashCode() {
final int prime = 31;
int hashCode = 1;
hashCode = prime * hashCode + ((getQueueUrl() == null) ? 0 : getQueueUrl().hashCode());
hashCode = prime * hashCode
+ ((getAttributeNames() == null) ? 0 : getAttributeNames().hashCode());
hashCode = prime
* hashCode
+ ((getMessageAttributeNames() == null) ? 0 : getMessageAttributeNames().hashCode());
hashCode = prime * hashCode
+ ((getMaxNumberOfMessages() == null) ? 0 : getMaxNumberOfMessages().hashCode());
hashCode = prime * hashCode
+ ((getVisibilityTimeout() == null) ? 0 : getVisibilityTimeout().hashCode());
hashCode = prime * hashCode
+ ((getWaitTimeSeconds() == null) ? 0 : getWaitTimeSeconds().hashCode());
hashCode = prime
* hashCode
+ ((getReceiveRequestAttemptId() == null) ? 0 : getReceiveRequestAttemptId()
.hashCode());
return hashCode;
}
代码示例来源:origin: aws-amplify/aws-sdk-android
ReceiveMessageRequest other = (ReceiveMessageRequest) obj;
if (other.getQueueUrl() == null ^ this.getQueueUrl() == null)
return false;
if (other.getQueueUrl() != null && other.getQueueUrl().equals(this.getQueueUrl()) == false)
return false;
if (other.getAttributeNames() == null ^ this.getAttributeNames() == null)
代码示例来源:origin: aws-amplify/aws-sdk-android
if (receiveMessageRequest.getQueueUrl() != null) {
prefix = "QueueUrl";
String queueUrl = receiveMessageRequest.getQueueUrl();
request.addParameter(prefix, StringUtils.fromString(queueUrl));
代码示例来源:origin: spring-cloud/spring-cloud-aws
private MessageExecutor(String logicalQueueName, Message message, QueueAttributes queueAttributes) {
this.logicalQueueName = logicalQueueName;
this.message = message;
this.queueUrl = queueAttributes.getReceiveMessageRequest().getQueueUrl();
this.hasRedrivePolicy = queueAttributes.hasRedrivePolicy();
this.deletionPolicy = queueAttributes.getDeletionPolicy();
}
代码示例来源:origin: com.amazonaws/aws-java-sdk-sqs
public Future<ReceiveMessageResult> receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessage(receiveMessageRequest, asyncHandler);
}
代码示例来源:origin: com.amazonaws/aws-java-sdk-sqs
@Override
public int hashCode() {
final int prime = 31;
int hashCode = 1;
hashCode = prime * hashCode + ((getQueueUrl() == null) ? 0 : getQueueUrl().hashCode());
hashCode = prime * hashCode + ((getAttributeNames() == null) ? 0 : getAttributeNames().hashCode());
hashCode = prime * hashCode + ((getMessageAttributeNames() == null) ? 0 : getMessageAttributeNames().hashCode());
hashCode = prime * hashCode + ((getMaxNumberOfMessages() == null) ? 0 : getMaxNumberOfMessages().hashCode());
hashCode = prime * hashCode + ((getVisibilityTimeout() == null) ? 0 : getVisibilityTimeout().hashCode());
hashCode = prime * hashCode + ((getWaitTimeSeconds() == null) ? 0 : getWaitTimeSeconds().hashCode());
hashCode = prime * hashCode + ((getReceiveRequestAttemptId() == null) ? 0 : getReceiveRequestAttemptId().hashCode());
return hashCode;
}
代码示例来源:origin: com.amazonaws/aws-android-sdk-sqs
@Override
public Future<ReceiveMessageResult> receiveMessageAsync(
ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest, ReceiveMessageResult> asyncHandler)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessage(receiveMessageRequest, asyncHandler);
}
代码示例来源:origin: com.amazonaws/aws-java-sdk-sqs
public ReceiveMessageResult receiveMessage(ReceiveMessageRequest receiveMessageRequest)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessageSync(receiveMessageRequest);
}
代码示例来源:origin: com.amazonaws/aws-java-sdk-sqs
public Future<ReceiveMessageResult> receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest)
throws AmazonServiceException, AmazonClientException {
ResultConverter.appendUserAgent(receiveMessageRequest, USER_AGENT);
QueueBuffer buffer = getQBuffer(receiveMessageRequest.getQueueUrl());
return buffer.receiveMessage(receiveMessageRequest, null);
}
内容来源于网络,如有侵权,请联系作者删除!