本文整理了Java中org.scribe.model.Response
类的一些代码示例,展示了Response
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response
类的具体详情如下:
包路径:org.scribe.model.Response
类名称:Response
[英]Represents an HTTP Response.
[中]表示HTTP响应。
代码示例来源:origin: google/data-transfer-project
private <T> SmugMugResponse<T> makeRequest(
String url, TypeReference<SmugMugResponse<T>> typeReference) throws IOException {
// Note: there are no request params that need to go here, because smugmug fully specifies
// which resource to get in the URL of a request, without using query params.
String fullUrl;
if (!url.contains("https://")) {
fullUrl = BASE_URL + url;
} else {
fullUrl = url;
}
OAuthRequest request =
new OAuthRequest(Verb.GET, fullUrl + "?_accept=application%2Fjson");
oAuthService.signRequest(accessToken, request);
final Response response = request.send();
if (response.getCode() < 200 || response.getCode() >= 300) {
throw new IOException(
String.format("Error occurred in request for %s : %s", url, response.getMessage()));
}
String result = response.getBody();
return mapper.readValue(result, typeReference);
}
代码示例来源:origin: google/data-transfer-project
public InputStream getImageAsStream(String urlStr) {
OAuthRequest request = new OAuthRequest(Verb.GET, urlStr);
oAuthService.signRequest(accessToken, request);
final Response response = request.send();
return response.getStream();
}
代码示例来源:origin: tumblr/jumblr
/**
* Instantiate a new JumblrException given a bad response to wrap
* @param response the response to wrap
*/
public JumblrException(Response response) {
this.responseCode = response.getCode();
String body = response.getBody();
JsonParser parser = new JsonParser();
try {
final JsonElement element = parser.parse(body);
if (element.isJsonObject()) {
JsonObject object = element.getAsJsonObject();
this.extractMessage(object);
this.extractErrors(object);
} else {
this.message = body;
}
} catch (JsonParseException ex) {
this.message = body;
}
}
代码示例来源:origin: multidots/android-app-common-tasks
@Override
protected Void doInBackground(String... params) {
System.out.println("001 OauthEnd doInBackground-->" + params[0]);
String url = params[0];
if (url.contains("user_refused")) {
setResult(RESULT_CANCELED);
finish();
} else {
final Uri uri = Uri.parse(url);
final String verifier = uri.getQueryParameter("oauth_verifier");
final Verifier v = new Verifier(verifier);
System.out.println("hp Verifier>>>> " + v.getValue());
final Token accessToken = oas_linkedin.getAccessToken(requestToken,
v);
final OAuthRequest request = new OAuthRequest(Verb.GET,
PROTECTED_RESOURCE_URL);
oas_linkedin.signRequest(accessToken, request);
Response response = request.send();
// TODO JSON response in intent RESPONSE
Intent intent = new Intent();
intent.putExtra("RESPONSE", response.getBody());
setResult(RESULT_OK, intent);
finish();
}
return null;
}
}
代码示例来源:origin: hoverruan/weiboclient4j
public static <T> List<T> parseJsonObject(Response response, TypeReference<List<T>> type)
throws WeiboClientException {
if (response.isSuccessful()) {
return parseJsonObject(response.getCode(), response.getBody(), type);
} else {
throw createException(response);
}
}
代码示例来源:origin: de.esoco/esoco-oauth
/***************************************
* {@inheritDoc}
*/
@Override
public int getCode()
{
return rResponse.getCode();
}
代码示例来源:origin: tumblr/jumblr
public String getRedirectUrl(String path) {
OAuthRequest request = this.constructGet(path, null);
sign(request);
boolean presetVal = HttpURLConnection.getFollowRedirects();
HttpURLConnection.setFollowRedirects(false);
Response response = request.send();
HttpURLConnection.setFollowRedirects(presetVal);
if (response.getCode() == 301 || response.getCode() == 302) {
return response.getHeader("Location");
} else {
throw new JumblrException(response);
}
}
代码示例来源:origin: org.scribe/scribe
Response(HttpURLConnection connection) throws IOException
{
try
{
connection.connect();
code = connection.getResponseCode();
message = connection.getResponseMessage();
headers = parseHeaders(connection);
stream = isSuccessful() ? connection.getInputStream() : connection.getErrorStream();
}
catch (UnknownHostException e)
{
throw new OAuthException("The IP address of a host could not be determined.", e);
}
}
代码示例来源:origin: org.scribe/scribe-up
Response doSend() throws IOException {
this.connection.setRequestMethod(this.verb.name());
if (this.connectTimeout != null) {
this.connection.setConnectTimeout(this.connectTimeout.intValue());
}
if (this.readTimeout != null) {
this.connection.setReadTimeout(this.readTimeout.intValue());
}
addHeaders(this.connection);
if (this.verb.equals(Verb.PUT) || this.verb.equals(Verb.POST)) {
addBody(this.connection, getByteBodyContents());
}
return new Response(this.connection);
}
代码示例来源:origin: tumblr/jumblr
/* package-visible for testing */ ResponseWrapper clear(Response response) {
if (response.getCode() == 200 || response.getCode() == 201) {
String json = response.getBody();
try {
Gson gson = new GsonBuilder().
registerTypeAdapter(JsonElement.class, new JsonElementDeserializer()).
create();
ResponseWrapper wrapper = gson.fromJson(json, ResponseWrapper.class);
if (wrapper == null) {
throw new JumblrException(response);
}
wrapper.setClient(client);
return wrapper;
} catch (JsonSyntaxException ex) {
throw new JumblrException(response);
}
} else {
throw new JumblrException(response);
}
}
代码示例来源:origin: multidots/android-app-common-tasks
@Override
protected Void doInBackground(String... params) {
System.out.println("001 OauthEnd doInBackground-->" + params[0]);
String url = params[0];
if (url.contains("user_refused")) {
setResult(RESULT_CANCELED);
finish();
} else {
final Uri uri = Uri.parse(url);
final String verifier = uri.getQueryParameter("oauth_verifier");
final Verifier v = new Verifier(verifier);
System.out.println("hp Verifier>>>> " + v.getValue());
final Token accessToken = oas_linkedin.getAccessToken(requestToken,
v);
final OAuthRequest request = new OAuthRequest(Verb.GET,
PROTECTED_RESOURCE_URL);
oas_linkedin.signRequest(accessToken, request);
Response response = request.send();
// TODO JSON response in intent RESPONSE
Intent intent = new Intent();
intent.putExtra("RESPONSE", response.getBody());
setResult(RESULT_OK, intent);
finish();
}
return null;
}
}
代码示例来源:origin: hoverruan/weiboclient4j
public static <T> T parseJsonObject(Response response, Class<T> clazz) throws WeiboClientException {
if (response.isSuccessful()) {
return parseJsonObject(response.getCode(), response.getBody(), clazz);
} else {
throw createException(response);
}
}
代码示例来源:origin: org.scribe/scribe
public boolean isSuccessful()
{
return getCode() >= 200 && getCode() < 400;
}
代码示例来源:origin: org.scribe/scribe
Response doSend(RequestTuner tuner) throws IOException
{
connection.setRequestMethod(this.verb.name());
if (connectTimeout != null)
{
connection.setConnectTimeout(connectTimeout.intValue());
}
if (readTimeout != null)
{
connection.setReadTimeout(readTimeout.intValue());
}
addHeaders(connection);
if (verb.equals(Verb.PUT) || verb.equals(Verb.POST))
{
addBody(connection, getByteBodyContents());
}
tuner.tune(this);
return new Response(connection);
}
代码示例来源:origin: hburgmeier/jerseyoauth2
protected void throwClientException(Response response) throws ClientException
{
int code = response.getCode();
String body = response.getBody();
throw new ClientException(Integer.toString(code)+" "+body);
}
代码示例来源:origin: bill1012/AdminEAP
@Override
public OAuthUser getOAuthUser(Token accessToken) {
OAuthRequest request = new OAuthRequest(Verb.GET, PROTECTED_RESOURCE_URL);
this.signRequest(accessToken, request);
Response response = request.send();
OAuthUser oAuthUser = new OAuthUser();
oAuthUser.setoAuthType(getoAuthType());
Object result = JSON.parse(response.getBody());
oAuthUser.setoAuthId(JSONPath.eval(result, "$.id").toString());
oAuthUser.setUserName(JSONPath.eval(result, "$.login").toString());
return oAuthUser;
}
代码示例来源:origin: org.apache.camel/camel-yammer
private String send(Verb verb, String params) throws Exception {
String url = apiUrl + ((params != null) ? params : "");
OAuthRequest request = new OAuthRequest(verb, url);
request.addQuerystringParameter(OAuthConstants.ACCESS_TOKEN, apiAccessToken);
// For more details on the “Bearer” token refer to http://tools.ietf.org/html/draft-ietf-oauth-v2-bearer-23
StringBuilder sb = new StringBuilder();
sb.append("Bearer ");
sb.append(apiAccessToken);
request.addHeader("Authorization", sb.toString());
if (LOG.isDebugEnabled()) {
LOG.debug("Yammer request url: {}", request.getCompleteUrl());
}
Response response = request.send();
if (response.isSuccessful()) {
return response.getBody();
} else {
throw new Exception(String.format("Failed to poll %s. Got response code %s and body: %s", getApiUrl(), response.getCode(), response.getBody()));
}
}
代码示例来源:origin: google/data-transfer-project
if (response.getCode() < 200 || response.getCode() >= 300) {
throw new IOException(
String.format("Error occurred in request for %s : %s", fullUrl, response.getMessage()));
return mapper.readValue(response.getBody(), typeReference);
代码示例来源:origin: tumblr/jumblr
/* package-visible for testing */ Token clearXAuth(Response response) {
if (response.getCode() == 200 || response.getCode() == 201) {
return parseXAuthResponse(response);
} else {
throw new JumblrException(response);
}
}
代码示例来源:origin: org.scribe/scribe
private String parseBodyContents()
{
body = StreamUtils.getStreamContents(getStream());
return body;
}
内容来源于网络,如有侵权,请联系作者删除!