public void execute() { DeleteDomainRequest request = new DeleteDomainRequest() .withDomainName(determineDomainName()); log.trace("Sending request [{}] for exchange [{}]...", request, exchange); this.sdbClient.deleteDomain(request); log.trace("Request sent"); }
@Override public void delete(CassandraRing ring) { String domain = domain(ring); if (ringsProvider.get().contains(domain)) { client.deleteDomain(new DeleteDomainRequest().withDomainName(domain)); } }
/** * {@inheritDoc} */ @Override public void drop() { this.credentials.aws().deleteDomain( new DeleteDomainRequest().withDomainName(this.table) ); }
/** * Running the delete-domain command over & over again on the same domain, or if the domain does NOT exist will NOT * result in a Amazon Exception * * @param domainName */ protected void dropDomain(final String domainName, final AmazonSimpleDB sdb) { try { LOGGER.debug("Dropping domain: {}", domainName); DeleteDomainRequest request = new DeleteDomainRequest(domainName); sdb.deleteDomain(request); LOGGER.debug("Dropped domain: {}", domainName); } catch(AmazonClientException amazonException) { throw SimpleDbExceptionTranslator.getTranslatorInstance().translateAmazonClientException(amazonException); } }
@Override public DeleteDomainResult deleteDomain(DeleteDomainRequest deleteDomainRequest) throws AmazonServiceException, AmazonClientException { this.deleteDomainRequest = deleteDomainRequest; return new DeleteDomainResult(); }
public void deleteTable(String tableName) { if (hasTable(tableName)) { logger.info("Deleting table: " + tableName); db.deleteDomain(new DeleteDomainRequest(tableName)); } }
public static void deleteDomain(String domainName) { getInstance().deleteDomain(new DeleteDomainRequest(domainName)); }