List of deleteTopic() Examples

Examples of deleteTopic()

com.amazonaws.services.sns.AmazonSNSClient.deleteTopic()

The DeleteTopic action deletes a topic and all its subscriptions. Deleting a topic might prevent some messages previously sent to the topic from being delivered to subscribers. This action is idempotent, so deleting a topic that does not exist does not result in an error.
@param deleteTopicRequest Container for the necessary parameters toexecute the DeleteTopic service method on AmazonSNS. @throws NotFoundException @throws AuthorizationErrorException @throws InternalErrorException @throws InvalidParameterException @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 AmazonSNS indicating either a problem with the data in the request, or a server side issue.
com.cloudera.oryx.kafka.util.ProduceData.deleteTopic()
com.comcast.cns.persistence.CNSTopicCassandraPersistence.deleteTopic()
com.comcast.cns.persistence.ICNSTopicPersistence.deleteTopic()
Delete an existing topic along with all subscriptions. @param arn @throws Exception

Examples of com.amazonaws.services.sns.AmazonSNSClient.deleteTopic()

      }
      
      // delete queue and topic
      
      DeleteTopicRequest  deleteTopicRequest = new DeleteTopicRequest(topicArn);
      sns.deleteTopic(deleteTopicRequest);
      
          sqs.deleteQueue(new DeleteQueueRequest(queueUrl));
          
          System.out.println("OK");

View Full Code Here

Examples of com.amazonaws.services.sns.AmazonSNSClient.deleteTopic()

          Thread.sleep(10000);
  
        for (String arn : topics) {
        
          DeleteTopicRequest  deleteTopicRequest = new DeleteTopicRequest(arn);
          sns.deleteTopic(deleteTopicRequest);
          
          logger.info("event=delete_topic arn=" + arn);
        }      
        }

View Full Code Here

Examples of com.cloudera.oryx.kafka.util.ProduceData.deleteTopic()


      // Sleep for a while before shutting down server to let it finish
      Thread.sleep(bufferMS);


    } finally {
      produce.deleteTopic();
    }


    return keyMessages;
  }

View Full Code Here

Examples of com.cloudera.oryx.kafka.util.ProduceData.deleteTopic()

      // Sleep for a while before shutting down server to let it finish
      Thread.sleep(bufferMS);


    } finally {
      inputProducer.deleteTopic();
      updateProducer.deleteTopic();
    }


    return keyMessages;
  }

View Full Code Here

Examples of com.comcast.cns.persistence.CNSTopicCassandraPersistence.deleteTopic()


        } finally {
        
            if (topicArn != null) {
                try {
                    topicHandler.deleteTopic(topicArn);
                } catch (Exception e) { }
            }
        }
    }

View Full Code Here

Examples of com.comcast.cns.persistence.CNSTopicCassandraPersistence.deleteTopic()


      CNSTopic t = topicHandler.createTopic(topicName, topicName, userId2);
      topicArn = t.getArn();
      
      try {
                topicHandler.deleteTopic(topicArn); //delete any pre-existing state
            } catch (Exception e) { }
            
            t = topicHandler.createTopic(topicName, topicName, userId2);
            topicArn = t.getArn();

View Full Code Here

Examples of com.comcast.cns.persistence.CNSTopicCassandraPersistence.deleteTopic()


    } finally {
    
      if (topicArn != null) {
        try {
          topicHandler.deleteTopic(topicArn);
        } catch (Exception e) { }
      }
    }
  }

View Full Code Here

Examples of com.comcast.cns.persistence.CNSTopicCassandraPersistence.deleteTopic()


    } finally {
    
      if (topicArn != null) {
        try {
          topicHandler.deleteTopic(topicArn);
        } catch (Exception e) { }
      }
    }
  }

View Full Code Here

Examples of com.comcast.cns.persistence.CNSTopicCassandraPersistence.deleteTopic()


        } finally {
        
            if (topicArn != null) {
                try {
                    topicHandler.deleteTopic(topicArn);
                } catch (Exception e) { }
            }
            
            logger.info("List subscriptions response time is " + (ts2 - ts1) + " ms");
        }

View Full Code Here

Examples of com.comcast.cns.persistence.ICNSTopicPersistence.deleteTopic()


    } finally {
    
      if (topicArn != null) {
        try {
          topicHandler.deleteTopic(topicArn);
        } catch (Exception e) { }
      }
    }
  }

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.