@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()); } }
public Observable<DeleteQueueResult> deleteQueueAsync(DeleteQueueRequest request) { return Observable.from(sqsClient.deleteQueueAsync(request)); }
public Observable<DeleteQueueResult> deleteQueueAsync(String queueUrl) { return Observable.from(sqsClient.deleteQueueAsync(queueUrl)); }
/** * <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); }
/** * <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 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); }