public class StreamClient extends Object implements AutoCloseable
| Modifier and Type | Class and Description |
|---|---|
static class |
StreamClient.AbiquoAPIOAuth |
static class |
StreamClient.Builder |
static interface |
StreamClient.SSLConfiguration |
static class |
StreamClient.Traces |
| Modifier and Type | Field and Description |
|---|---|
static DateFormat |
dateFormat |
String |
filters |
com.ning.http.client.AsyncHttpClient |
httpClient |
static com.fasterxml.jackson.databind.ObjectMapper |
json |
Long |
lastEventProcessed |
| Modifier and Type | Method and Description |
|---|---|
static StreamClient.Builder |
builder(String endpointToM,
String endpointToApi) |
void |
close() |
void |
connect() |
List<Trace> |
getEventsFromApiAndProcessCallback(StreamClient client) |
protected void |
processTrace(Trace trace) |
public final String filters
public Long lastEventProcessed
public static final com.fasterxml.jackson.databind.ObjectMapper json
public static final DateFormat dateFormat
public com.ning.http.client.AsyncHttpClient httpClient
public void connect()
throws IOException
IOExceptionprotected void processTrace(Trace trace)
public void close()
throws IOException
close in interface AutoCloseableIOExceptionpublic List<Trace> getEventsFromApiAndProcessCallback(StreamClient client)
public static StreamClient.Builder builder(String endpointToM, String endpointToApi)
Copyright © 2008–2020 Abiquo Holdings S.L.. All rights reserved.