View Javadoc

1   /**
2    *
3    * Copyright (C) 2011 Cloud Conscious, LLC. <info@cloudconscious.com>
4    *
5    * ====================================================================
6    * Licensed under the Apache License, Version 2.0 (the "License");
7    * you may not use this file except in compliance with the License.
8    * You may obtain a copy of the License at
9    *
10   * http://www.apache.org/licenses/LICENSE-2.0
11   *
12   * Unless required by applicable law or agreed to in writing, software
13   * distributed under the License is distributed on an "AS IS" BASIS,
14   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15   * See the License for the specific language governing permissions and
16   * limitations under the License.
17   * ====================================================================
18   */
19  package org.jclouds.http.handlers;
20  
21  import javax.inject.Singleton;
22  
23  import org.jclouds.http.HttpCommand;
24  import org.jclouds.http.HttpResponse;
25  import org.jclouds.http.HttpRetryHandler;
26  import org.jclouds.http.annotation.ClientError;
27  import org.jclouds.http.annotation.Redirection;
28  import org.jclouds.http.annotation.ServerError;
29  
30  import com.google.common.annotations.VisibleForTesting;
31  import com.google.inject.Inject;
32  
33  /**
34   * Delegates to {@link HttpRetryHandler HttpRetryHandlers} who are annotated according to the
35   * response codes they relate to.
36   * 
37   * @author Adrian Cole
38   */
39  @Singleton
40  public class DelegatingRetryHandler implements HttpRetryHandler {
41  
42     @VisibleForTesting
43     @Inject(optional = true)
44     @Redirection
45     HttpRetryHandler redirectionRetryHandler;
46  
47     @VisibleForTesting
48     @Inject(optional = true)
49     @ClientError
50     HttpRetryHandler clientErrorRetryHandler;
51  
52     @VisibleForTesting
53     @Inject(optional = true)
54     @ServerError
55     HttpRetryHandler serverErrorRetryHandler;
56  
57     @Inject
58     public DelegatingRetryHandler(BackoffLimitedRetryHandler backOff,
59              RedirectionRetryHandler redirectionRetryHandler) {
60        this.serverErrorRetryHandler = backOff;
61        this.redirectionRetryHandler = redirectionRetryHandler;
62        this.clientErrorRetryHandler = HttpRetryHandler.NEVER_RETRY;
63     }
64  
65     public boolean shouldRetryRequest(HttpCommand command, HttpResponse response) {
66        int statusCode = response.getStatusCode();
67        boolean retryRequest = false;
68        if (statusCode >= 300 && statusCode < 400) {
69           retryRequest = redirectionRetryHandler.shouldRetryRequest(command, response);
70        } else if (statusCode >= 400 && statusCode < 500) {
71           retryRequest = clientErrorRetryHandler.shouldRetryRequest(command, response);
72        } else if (statusCode >= 500) {
73           retryRequest = serverErrorRetryHandler.shouldRetryRequest(command, response);
74        }
75        return retryRequest;
76     }
77  
78     public HttpRetryHandler getRedirectionRetryHandler() {
79        return redirectionRetryHandler;
80     }
81  
82     public HttpRetryHandler getClientErrorRetryHandler() {
83        return clientErrorRetryHandler;
84     }
85  
86     public HttpRetryHandler getServerErrorRetryHandler() {
87        return serverErrorRetryHandler;
88     }
89  }