read timeouts for access token and request token calls

src/main/java/org/scribe/oauth/OAuth10aServiceImpl.java

@@ -5,6 +5,7 @@
 import org.scribe.builder.api.*;
 import org.scribe.model.*;
 import org.scribe.utils.*;
+import java.util.concurrent.TimeUnit;
 
 /**
  * OAuth 1.0a implementation of {@link OAuthService}
@@ -33,7 +34,7 @@ public OAuth10aServiceImpl(DefaultApi10a api, OAuthConfig config)
   /**
    * {@inheritDoc}
    */
-  public Token getRequestToken()
+  public Token getRequestToken(int timeout, TimeUnit unit)
   {
     config.log("obtaining request token from " + api.getRequestTokenEndpoint());
     OAuthRequest request = new OAuthRequest(api.getRequestTokenVerb(), api.getRequestTokenEndpoint());
@@ -44,6 +45,7 @@ public Token getRequestToken()
     appendSignature(request);
 
     config.log("sending request...");
+    request.setReadTimeout(timeout, unit);
     Response response = request.send();
     String body = response.getBody();
 
@@ -52,6 +54,11 @@ public Token getRequestToken()
     return api.getRequestTokenExtractor().extract(body);
   }
 
+  public Token getRequestToken()
+  {
+    return getRequestToken(2, TimeUnit.SECONDS);
+  }
+
   private void addOAuthParams(OAuthRequest request, Token token)
   {
     request.addOAuthParameter(OAuthConstants.TIMESTAMP, api.getTimestampService().getTimestampInSeconds());
@@ -68,7 +75,7 @@ private void addOAuthParams(OAuthRequest request, Token token)
   /**
    * {@inheritDoc}
    */
-  public Token getAccessToken(Token requestToken, Verifier verifier)
+  public Token getAccessToken(Token requestToken, Verifier verifier, int timeout, TimeUnit unit)
   {
     config.log("obtaining access token from " + api.getAccessTokenEndpoint());
     OAuthRequest request = new OAuthRequest(api.getAccessTokenVerb(), api.getAccessTokenEndpoint());
@@ -78,10 +85,16 @@ public Token getAccessToken(Token requestToken, Verifier verifier)
     config.log("setting token to: " + requestToken + " and verifier to: " + verifier);
     addOAuthParams(request, requestToken);
     appendSignature(request);
+    request.setReadTimeout(timeout, unit);
     Response response = request.send();
     return api.getAccessTokenExtractor().extract(response.getBody());
   }
 
+  public Token getAccessToken(Token requestToken, Verifier verifier)
+  {
+    return getAccessToken(requestToken, verifier, 2, TimeUnit.SECONDS);
+  }
+
   /**
    * {@inheritDoc}
    */