Package com.abiquo.apiclient.stream

Class StreamClient.Builder

java.lang.Object

com.abiquo.apiclient.stream.StreamClient.Builder

Enclosing class:

StreamClient

public static class StreamClient.Builder
extends Object

Method Summary

Modifier and Type	Method	Description
StreamClient.Builder	addCallback(Consumer<com.abiquo.tracing.model.Trace> callback)	Add a reaction to trace events
StreamClient.Builder	addFilterByAction(String action)	Filter by type of action
StreamClient.Builder	addFilterByEnterprise(Integer enterpriseId)	Filter by enterprise ID
StreamClient.Builder	addFilterByEntity(String entity)	Filter by type of entity
StreamClient.Builder	addFilterBySeverity(String severity)	Filter by severity
StreamClient.Builder	addFilterByUser(Integer userId)	Filter by user ID
StreamClient.Builder	afterReconnect(Consumer<StreamClient> afterReconnect)	Run after reconnection succeed
StreamClient.Builder	basicAuth(String username, String password)	Authenticate using user and password
StreamClient.Builder	beforeReconnect(Consumer<StreamClient> beforeReconnect)	Run before attempt reconnection
StreamClient	build()
StreamClient.Builder	oauth(String apiKey, String apiSecret, String token, String tokenSecret)	Authenticate using an authorized OAuth application
StreamClient.Builder	pauseBeforeReconnectInSeconds(int seconds)	Seconds before attempt reconnect (default 5 seconds)
StreamClient.Builder	reconnect()	Activate reconnection (default false)
StreamClient.Builder	reconnectAttempts(int attempts)	Number of reconnection attempts (default 10)
StreamClient.Builder	sslConfiguration(StreamClient.SSLConfiguration sslConfiguration)	Custom SSL configuration

Methods inherited from class java.lang.Object

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

Method Detail

basicAuth

public StreamClient.Builder basicAuth(String username,
                                      String password)

Authenticate using user and password

oauth

public StreamClient.Builder oauth(String apiKey,
                                  String apiSecret,
                                  String token,
                                  String tokenSecret)

Authenticate using an authorized OAuth application

sslConfiguration

public StreamClient.Builder sslConfiguration(StreamClient.SSLConfiguration sslConfiguration)

Custom SSL configuration

addFilterBySeverity

public StreamClient.Builder addFilterBySeverity(String severity)

Filter by severity

Parameters:

severity - : INFO, WARN, ERROR

addFilterByEntity

public StreamClient.Builder addFilterByEntity(String entity)

Filter by type of entity

Parameters:

entity - see https://wiki.abiquo.com/api/latest/EventsResource.html#list-events-types

addFilterByAction

public StreamClient.Builder addFilterByAction(String action)

Filter by type of action

Parameters:

entity - see https://wiki.abiquo.com/api/latest/EventsResource.html#list-events-types

addFilterByUser

public StreamClient.Builder addFilterByUser(Integer userId)

Filter by user ID

Parameters:

userId - identifier of the user

addFilterByEnterprise

public StreamClient.Builder addFilterByEnterprise(Integer enterpriseId)

Filter by enterprise ID

Parameters:

enterpriseId - identifier of the enterprise

addCallback

public StreamClient.Builder addCallback(Consumer<com.abiquo.tracing.model.Trace> callback)

Add a reaction to trace events

reconnect

public StreamClient.Builder reconnect()

Activate reconnection (default false)

reconnectAttempts

public StreamClient.Builder reconnectAttempts(int attempts)

Number of reconnection attempts (default 10)

pauseBeforeReconnectInSeconds

public StreamClient.Builder pauseBeforeReconnectInSeconds(int seconds)

Seconds before attempt reconnect (default 5 seconds)

beforeReconnect

public StreamClient.Builder beforeReconnect(Consumer<StreamClient> beforeReconnect)

Run before attempt reconnection

afterReconnect

public StreamClient.Builder afterReconnect(Consumer<StreamClient> afterReconnect)

Run after reconnection succeed

build

public StreamClient build()