Package com.abiquo.apiclient.stream

Class StreamClient

java.lang.Object

com.abiquo.apiclient.stream.StreamClient

All Implemented Interfaces:

AutoCloseable

public class StreamClient
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamClient.AbiquoAPIOAuth
static class	StreamClient.Builder
static interface	StreamClient.SSLConfiguration
static class	StreamClient.Traces

Field Summary

Fields

Modifier and Type	Field	Description
DateFormat	dateFormat
String	filters
com.ning.http.client.AsyncHttpClient	httpClient
static com.fasterxml.jackson.databind.ObjectMapper	json
Long	lastEventProcessed

Method Summary

Modifier and Type	Method	Description
static StreamClient.Builder	builder(String endpointToM, String endpointToApi)
void	close()
void	connect()
List<com.abiquo.tracing.model.Trace>	getEventsFromApiAndProcessCallback(StreamClient client)
protected void	processTrace(com.abiquo.tracing.model.Trace trace)

Methods inherited from class java.lang.Object

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

Field Detail

filters

public final String filters

lastEventProcessed

public Long lastEventProcessed

json

public static final com.fasterxml.jackson.databind.ObjectMapper json

dateFormat

public final DateFormat dateFormat

httpClient

public com.ning.http.client.AsyncHttpClient httpClient

Method Detail

connect

public void connect()
             throws IOException

Throws:

IOException

processTrace

protected void processTrace(com.abiquo.tracing.model.Trace trace)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

getEventsFromApiAndProcessCallback

public List<com.abiquo.tracing.model.Trace> getEventsFromApiAndProcessCallback(StreamClient client)

builder

public static StreamClient.Builder builder(String endpointToM,
                                           String endpointToApi)