List of validateConnection() Examples

Examples of 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
org.activemq.broker.BrokerClient.validateConnection()
Tests the connection to assert that it in fact is alive by asserting that a full round-trip to the client is possible. @param timeout the number of millisecods to wait before the connection is declared invalid @throws JMSException if the connection is invalid
org.apache.sqoop.validation.Validator.validateConnection()
Validate connection configuration object. @param connectionConfiguration Connection object to be validated @return Validation status
org.codehaus.activemq.broker.BrokerClient.validateConnection()
Tests the connection to assert that it in fact is alive by asserting that a full round-trip to the client is possible. @param timeout the number of millisecods to wait before the connection is declared invalid @throws JMSException if the connection is invalid
org.mule.api.transport.Connectable.validateConnection()
Test whether the connector is able to connect to its resource(s). This will allow a retry policy to go into effect in the case of failure. Implementations must call either:
- {@link RetryContext#setOk()} when no problems found (or no validation required).
- {@link RetryContext#setFailed(Throwable)} with a root cause for a connection failure.
Callers should then check for {@link RetryContext#isOk()}. The failure, if any, will be provided via the {@link RetryContext#getLastFailure()}. @return same retry context with status info set and any failures populated @throws Exception if the connector fails to connect @param retryContext

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

                    "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

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

        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

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

                    } 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

Examples of org.activemq.broker.BrokerClient.validateConnection()

      // Assert that the existing client is alive
      BrokerClient existingClient = (BrokerClient) clientIds.get(clientId);
      JMSException ex = null;
      boolean isValid = true;
      try {
        existingClient.validateConnection(timeout);
      } catch (JMSException e) {
        isValid = false;
        ex = e;
      }
      if (isValid) {

View Full Code Here

Examples of org.activemq.broker.BrokerClient.validateConnection()

      // Assert that the existing client is alive
      BrokerClient existingClient = (BrokerClient) clientIds.get(clientId);
      JMSException ex = null;
      boolean isValid = true;
      try {
        existingClient.validateConnection(timeout);
      } catch (JMSException e) {
        isValid = false;
        ex = e;
      }
      if (isValid) {

View Full Code Here

Examples of org.activemq.broker.BrokerClient.validateConnection()

      // Assert that the existing client is alive
      BrokerClient existingClient = (BrokerClient) clientIds.get(clientId);
      JMSException ex = null;
      boolean isValid = true;
      try {
        existingClient.validateConnection(timeout);
      } catch (JMSException e) {
        isValid = false;
        ex = e;
      }
      if (isValid) {

View Full Code Here

Examples of org.apache.sqoop.validation.Validator.validateConnection()


        // Transform form structures to objects for validations
        Object newConfigurationObject = ClassUtils.instantiate(connector.getConnectionConfigurationClass());
        FormUtils.fromForms(newConnection.getConnectorPart().getForms(), newConfigurationObject);


        Validation validation = validator.validateConnection(newConfigurationObject);
        if (validation.getStatus().canProceed()) {
          updateConnection(newConnection, tx);
        } else {
          logInvalidModelObject("connection", newConnection, validation);
          upgradeSuccessful = false;

View Full Code Here

Examples of org.apache.sqoop.validation.Validator.validateConnection()


        // Transform form structures to objects for validations
        Object newConfigurationObject = ClassUtils.instantiate(FrameworkManager.getInstance().getConnectionConfigurationClass());
        FormUtils.fromForms(newConnection.getFrameworkPart().getForms(), newConfigurationObject);


        Validation validation = validator.validateConnection(newConfigurationObject);
        if (validation.getStatus().canProceed()) {
          updateConnection(newConnection, tx);
        } else {
          logInvalidModelObject("connection", newConnection, validation);
          upgradeSuccessful = false;

View Full Code Here

Examples of org.apache.sqoop.validation.Validator.validateConnection()


    // Validate both parts
    Validation connectorValidation =
      connectorValidator.validateConnection(connectorConfig);
    Validation frameworkValidation =
      frameworkValidator.validateConnection(frameworkConfig);


    Status finalStatus = Status.getWorstStatus(connectorValidation.getStatus(),
      frameworkValidation.getStatus());


    // Return back validations in all cases

View Full Code Here

Examples of org.apache.sqoop.validation.Validator.validateConnection()


    // Validate both parts
    Validation connectorValidation =
      connectorValidator.validateConnection(connectorConfig);
    Validation frameworkValidation =
      frameworkValidator.validateConnection(frameworkConfig);


    Status finalStatus = Status.getWorstStatus(connectorValidation.getStatus(),
      frameworkValidation.getStatus());


    // Return back validations in all cases

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.