项目:awslocal
文件:DirectorySQS.java
@Override
public DeleteQueueResult deleteQueue(DeleteQueueRequest deleteQueueRequest) throws AmazonClientException {
final DirectorySQSQueue queue = getQueueFromUrl(deleteQueueRequest.getQueueUrl(),true);
try {
Files.delete(queue.getQueuePath());
return new DeleteQueueResult();
} catch (IOException e) {
throw new AmazonServiceException("Could not delete queue: " + queue.getQueuePath());
}
}
项目:reactive-sqs-client
文件:ReactiveSqsClient.java
public Observable<DeleteQueueResult> deleteQueueAsync(DeleteQueueRequest request) {
return Observable.from(sqsClient.deleteQueueAsync(request));
}
项目:reactive-sqs-client
文件:ReactiveSqsClient.java
public Observable<DeleteQueueResult> deleteQueueAsync(String queueUrl) {
return Observable.from(sqsClient.deleteQueueAsync(queueUrl));
}
项目:amazon-sqs-java-extended-client-lib
文件:AmazonSQSExtendedClientBase.java
/**
* <p>
* Deletes the queue specified by the <b>queue URL</b>,regardless of
* whether the queue is empty. If the specified queue does not exist,Amazon
* SQS returns a successful response.
* </p>
* <p>
* <b>IMPORTANT:</b> Use DeleteQueue with care; once you delete your queue,* any messages in the queue are no longer available.
* </p>
* <p>
* When you delete a queue,the deletion process takes up to 60 seconds.
* Requests you send involving that queue during the 60 seconds might
* succeed. For example,a SendMessage request might succeed,but after the
* 60 seconds,the queue and that message you sent no longer exist. Also,* when you delete a queue,you must wait at least 60 seconds before
* creating a queue with the same name.
* </p>
* <p>
* We reserve the right to delete queues that have had no activity for more
* than 30 days. For more information,see <a href=
* "http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/SQSConcepts.html"
* > How Amazon SQS Queues Work </a> in the <i>Amazon SQS Developer
* Guide</i> .
* </p>
*
* @param deleteQueueRequest
* Container for the necessary parameters to execute the
* DeleteQueue service method on AmazonSQS.
*
*
*
* @throws AmazonClientException
* If any internal errors are encountered inside the client
* while attempting to make the request or handle the response.
* For example if a network connection is not available.
* @throws AmazonServiceException
* If an error response is returned by AmazonSQS indicating
* either a problem with the data in the request,or a server
* side issue.
*/
public DeleteQueueResult deleteQueue(DeleteQueueRequest deleteQueueRequest)
throws AmazonServiceException,AmazonClientException {
return amazonSqsToBeExtended.deleteQueue(deleteQueueRequest);
}
项目:amazon-sqs-java-extended-client-lib
文件:AmazonSQSExtendedClientBase.java
/**
* <p>
* Deletes the queue specified by the <b>queue URL</b>,see <a href=
* "http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/SQSConcepts.html"
* > How Amazon SQS Queues Work </a> in the <i>Amazon SQS Developer
* Guide</i> .
* </p>
*
* @param queueUrl
* The URL of the Amazon SQS queue to take action on.
*
* @return The response from the DeleteQueue service method,as returned by
* AmazonSQS.
*
*
* @throws AmazonClientException
* If any internal errors are encountered inside the client
* while attempting to make the request or handle the response.
* For example if a network connection is not available.
* @throws AmazonServiceException
* If an error response is returned by AmazonSQS indicating
* either a problem with the data in the request,or a server
* side issue.
*/
public DeleteQueueResult deleteQueue(String queueUrl) throws AmazonServiceException,AmazonClientException {
return amazonSqsToBeExtended.deleteQueue(queueUrl);
}