@Test
public void testDeleteConsumerGroup() throws Exception {

    //Create a ConsumerGroup to delete
    CreateConsumerGroupRequest request = new CreateConsumerGroupRequest();
    final String destination = "/foo/bar";
    final String consumerGroup = "TestConsumerGroup";
    final int lockTimeout = new Random().nextInt();
    final int maxDelivery = new Random().nextInt();
    final String email = "foo@bar.com";
    final int skipOlder = new Random().nextInt();
    final long timestamp = new Date().getTime();
    request.setDestinationPath(destination);
    request.setConsumerGroupName(consumerGroup);
    request.setLockTimeoutInSeconds(lockTimeout);
    request.setMaxDeliveryCount(maxDelivery);
    request.setOwnerEmail(email);
    request.setSkipOlderMessagesInSeconds(skipOlder);
    request.setStartFrom(timestamp);
    ConsumerGroupDescription response = client.createConsumerGroup(request);
    assert (response.getDestinationPath().equals(destination));
    assert (response.getConsumerGroupName().equals(consumerGroup));
    DeleteConsumerGroupRequest deleteRequest = new DeleteConsumerGroupRequest();
    deleteRequest.setDestinationPath(destination);
    deleteRequest.setConsumerGroupName(consumerGroup);
    // Simple test case where we delete an existing ConsumerGroup
    try {
        client.deleteConsumerGroup(deleteRequest);
    } catch (RuntimeException e) {
        assert (false);
    }
    // Client should not be able to delete a nonexistent ConsumerGroup
    thrown.expect(EntityNotExistsError.class);
    client.deleteConsumerGroup(deleteRequest);
}