Package ch.rswk.meta.client

Class RestClient

java.lang.Object

ch.rswk.meta.client.RestClient

public class RestClient
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private String	activeToken
private final org.eclipse.jetty.client.HttpClient	client
private static final org.slf4j.Logger	LOG
private final String	password
private final String	tokenResourceUri
private final String	user

Constructor Summary

Constructors

Constructor	Description
RestClient(org.eclipse.jetty.client.HttpClient client, String engine, @Nullable String password, String user)

Method Summary

Modifier and Type	Method	Description
private org.eclipse.jetty.client.api.Response	downloadFile(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier, boolean requestToken, Path target)
org.eclipse.jetty.client.api.Response	downloadFile(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier, Path target)
private org.eclipse.jetty.client.api.Request	prepareRequest(org.eclipse.jetty.client.api.Request request)
private boolean	renewToken()
static org.eclipse.jetty.client.api.ContentResponse	renewToken(org.eclipse.jetty.client.HttpClient client, @Nullable String password, String uri, String user)
void	resetToken()
org.eclipse.jetty.client.api.ContentResponse	send(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier)
private org.eclipse.jetty.client.api.ContentResponse	send(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier, boolean requestToken)
com.google.common.util.concurrent.ListenableFuture<org.eclipse.jetty.client.api.ContentResponse>	sendAsync(int maxLength, Supplier<org.eclipse.jetty.client.api.Request> requestSupplier)
com.google.common.util.concurrent.ListenableFuture<org.eclipse.jetty.client.api.ContentResponse>	sendAsync(int maxLength, Supplier<org.eclipse.jetty.client.api.Request> requestSupplier, boolean requestToken)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

client

private final org.eclipse.jetty.client.HttpClient client

password

private final String password

tokenResourceUri

private final String tokenResourceUri

user

private final String user

activeToken

private String activeToken

Constructor Details

RestClient

public RestClient(org.eclipse.jetty.client.HttpClient client,
 String engine,
 @Nullable String password,
 String user)

Method Details

downloadFile

public org.eclipse.jetty.client.api.Response downloadFile(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier,
 Path target)
                                                   throws InterruptedException,
TimeoutException,
ExecutionException

Throws:

InterruptedException

TimeoutException

ExecutionException

downloadFile

private org.eclipse.jetty.client.api.Response downloadFile(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier,
 boolean requestToken,
 Path target)
                                                    throws InterruptedException,
TimeoutException,
ExecutionException

Throws:

InterruptedException

TimeoutException

ExecutionException

prepareRequest

private org.eclipse.jetty.client.api.Request prepareRequest(org.eclipse.jetty.client.api.Request request)
                                                     throws InterruptedException

Throws:

InterruptedException

renewToken

private boolean renewToken()
                    throws InterruptedException

Throws:

InterruptedException

renewToken

public static org.eclipse.jetty.client.api.ContentResponse renewToken(org.eclipse.jetty.client.HttpClient client,
 @Nullable String password,
 String uri,
 String user)
                                                               throws Exception

Throws:

Exception

resetToken

public void resetToken()

send

public org.eclipse.jetty.client.api.ContentResponse send(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier)
                                                  throws InterruptedException,
TimeoutException,
ExecutionException

Throws:

InterruptedException

TimeoutException

ExecutionException

send

private org.eclipse.jetty.client.api.ContentResponse send(Supplier<org.eclipse.jetty.client.api.Request> requestSupplier,
 boolean requestToken)
                                                   throws InterruptedException,
TimeoutException,
ExecutionException

Throws:

InterruptedException

TimeoutException

ExecutionException

sendAsync

public com.google.common.util.concurrent.ListenableFuture<org.eclipse.jetty.client.api.ContentResponse> sendAsync(int maxLength,
 Supplier<org.eclipse.jetty.client.api.Request> requestSupplier)
                                                                                                           throws InterruptedException

Throws:

InterruptedException

sendAsync

public com.google.common.util.concurrent.ListenableFuture<org.eclipse.jetty.client.api.ContentResponse> sendAsync(int maxLength,
 Supplier<org.eclipse.jetty.client.api.Request> requestSupplier,
 boolean requestToken)
                                                                                                           throws InterruptedException

Throws:

InterruptedException