@Test public void testBucketVirtualHostStyleAmazon() { final Host host = new Host(new S3Protocol(), new S3Protocol().getDefaultHostname()); assertFalse(new S3Session(host).connect(Proxy.DIRECT, new DisabledHostKeyCallback(), new DisabledLoginCallback()) .getConfiguration().getBoolProperty("s3service.disable-dns-buckets", true)); }
@Override public RequestEntityRestStorageService connect(final Proxy proxy, final HostKeyCallback hostkey, final LoginCallback prompt) { final HttpClientBuilder configuration = builder.build(proxy, this, prompt); if(S3Session.isAwsHostname(host.getHostname())) { configuration.setServiceUnavailableRetryStrategy(new S3TokenExpiredResponseInterceptor(this, new ThreadLocalHostnameDelegatingTrustManager(trust, host.getHostname()), key, prompt)); } return new RequestEntityRestStorageService(this, configuration); }
S3Session extends HttpSession<RequestEntityRestStorageService> { @Override public RequestEntityRestStorageService connect(final Proxy proxy, final HostKeyCallback hostkey, final LoginCallback prompt) { final HttpClientBuilder configuration = builder.build(proxy, this, prompt); if(S3Session.isAwsHostname(host.getHostname())) { configuration.setServiceUnavailableRetryStrategy(new S3TokenExpiredResponseInterceptor(this, new ThreadLocalHostnameDelegatingTrustManager(trust, host.getHostname()), key, prompt)); } return new RequestEntityRestStorageService(this, configuration); } }
S3Session extends HttpSession<RequestEntityRestStorageService> { @Override public RequestEntityRestStorageService connect(final Proxy proxy, final HostKeyCallback hostkey, final LoginCallback prompt) { final HttpClientBuilder configuration = builder.build(proxy, this, prompt); if(S3Session.isAwsHostname(host.getHostname())) { configuration.setServiceUnavailableRetryStrategy(new S3TokenExpiredResponseInterceptor(this, new ThreadLocalHostnameDelegatingTrustManager(trust, host.getHostname()), key, prompt)); } return new RequestEntityRestStorageService(this, configuration); } S3Session(final Host host);  S3Session(final Host host, final X509TrustManager trust, final X509KeyManager key); }
S3Session extends HttpSession<RequestEntityRestStorageService> { @Override public RequestEntityRestStorageService connect(final Proxy proxy, final HostKeyCallback hostkey, final LoginCallback prompt) { final HttpClientBuilder configuration = builder.build(proxy, this, prompt); if(S3Session.isAwsHostname(host.getHostname())) { configuration.setServiceUnavailableRetryStrategy(new S3TokenExpiredResponseInterceptor(this, new ThreadLocalHostnameDelegatingTrustManager(trust, host.getHostname()), key, prompt)); } return new RequestEntityRestStorageService(this, configuration); } S3Session(final Host host);  S3Session(final Host host, final X509TrustManager trust, final X509KeyManager key); S3Protocol.AuthenticationHeaderSignatureVersion getSignatureVersion(); void setSignatureVersion(final S3Protocol.AuthenticationHeaderSignatureVersion authenticationHeaderSignatureVersion); @Override RequestEntityRestStorageService connect(final Proxy proxy, final HostKeyCallback hostkey, final LoginCallback prompt); @Override void login(final Proxy proxy, final LoginCallback prompt, final CancelCallback cancel); static boolean isAwsHostname(final String hostname); @Override @SuppressWarnings("unchecked") T _getFeature(final Class<T> type); }
S3Session extends HttpSession<RequestEntityRestStorageService> { @Override public RequestEntityRestStorageService connect(final Proxy proxy, final HostKeyCallback hostkey, final LoginCallback prompt) { final HttpClientBuilder configuration = builder.build(proxy, this, prompt); if(S3Session.isAwsHostname(host.getHostname())) { configuration.setServiceUnavailableRetryStrategy(new S3TokenExpiredResponseInterceptor(this, new ThreadLocalHostnameDelegatingTrustManager(trust, host.getHostname()), key, prompt)); } return new RequestEntityRestStorageService(this, configuration); } S3Session(final Host host);  S3Session(final Host host, final X509TrustManager trust, final X509KeyManager key); S3Protocol.AuthenticationHeaderSignatureVersion getSignatureVersion(); void setSignatureVersion(final S3Protocol.AuthenticationHeaderSignatureVersion authenticationHeaderSignatureVersion); @Override RequestEntityRestStorageService connect(final Proxy proxy, final HostKeyCallback hostkey, final LoginCallback prompt); @Override void login(final Proxy proxy, final LoginCallback prompt, final CancelCallback cancel); static boolean isAwsHostname(final String hostname); @Override @SuppressWarnings("unchecked") T _getFeature(final Class<T> type);  }