Examples of com.streamreduce.util.ExternalIntegrationClient.validateConnection()

Class com.streamreduce.util.ExternalIntegrationClient

Examples of com.streamreduce.util.ExternalIntegrationClient.validateConnection()

com.streamreduce.util.ExternalIntegrationClient.validateConnection()
Validates the client by using the information in the connection to make a request that will ensure the client is valid. @throws com.streamreduce.core.service.exception.InvalidCredentialsException if the connection's credentials are invalid @throws java.io.IOException if anything else goes wrong

                    "support validation via an external client.");
            return;
        }


        ExternalIntegrationClient externalClient = connectionProvider.getClient(connection);
        externalClient.validateConnection();
        externalClient.cleanUp();
    }


    private void validateOutboundConfigurations(Set<OutboundConfiguration> outboundConfigurations) throws InvalidCredentialsException, IOException {
        if (CollectionUtils.isEmpty(outboundConfigurations)) {

View Full Code Here

        try {
            for (OutboundConfiguration outboundConfiguration : outboundConfigurations) {
                if (outboundConfiguration.getProtocol().equals("s3")) {
                    AWSClient awsClient = new AWSClient(outboundConfiguration);
                    externalClient = awsClient;
                    externalClient.validateConnection();
                    try {
                        awsClient.createBucket(outboundConfiguration);
                    } catch (IllegalStateException e) { //thrown when a bucket name is already taken
                        throw new InvalidOutboundConfigurationException(e.getMessage(), e);
                    }

View Full Code Here

                    } catch (IllegalStateException e) { //thrown when a bucket name is already taken
                        throw new InvalidOutboundConfigurationException(e.getMessage(), e);
                    }
                } else if (outboundConfiguration.getProtocol().equals("webhdfs")) {
                    externalClient = new WebHDFSClient(outboundConfiguration);
                    externalClient.validateConnection();
                }
            }
        } finally {
            if (externalClient != null) {
                externalClient.cleanUp();

View Full Code Here

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.