org.waarp.openr66.protocol.monitoring

Class HttpMonitoringExporterClient

java.lang.Object

org.waarp.openr66.protocol.monitoring.HttpMonitoringExporterClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class HttpMonitoringExporterClient
extends Object
implements Closeable

HttpMonitoringExporterClient used by the MonitorExporterTransfers

Field Summary

Fields

Modifier and Type	Field and Description
static String	API_KEY
static String	BASIC
static String	BEARER
static String	HTTPS

Constructor Summary

Constructors

Constructor and Description
HttpMonitoringExporterClient(String remoteBaseUrl, String basicAuthent, String token, String apiKey, String endpoint, boolean keepConnection, io.netty.channel.EventLoopGroup group) Note that only one among (basicAuthent, token, apikey) is allowed and will be taken into account.

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isKeepConnection()
boolean	post(com.fasterxml.jackson.databind.node.ObjectNode monitoredTransfers, org.joda.time.DateTime start, org.joda.time.DateTime stop, String serverId)
void	setStatus(boolean ok)

Methods inherited from class java.lang.Object

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

Field Detail

HTTPS

public static final String HTTPS

See Also:

Constant Field Values

BASIC

public static final String BASIC

See Also:

Constant Field Values

BEARER

public static final String BEARER

See Also:

Constant Field Values

API_KEY

public static final String API_KEY

See Also:

Constant Field Values

Constructor Detail

HttpMonitoringExporterClient

public HttpMonitoringExporterClient(String remoteBaseUrl,
                                    String basicAuthent,
                                    String token,
                                    String apiKey,
                                    String endpoint,
                                    boolean keepConnection,
                                    io.netty.channel.EventLoopGroup group)

Note that only one among (basicAuthent, token, apikey) is allowed and will be taken into account.

Parameters:

remoteBaseUrl - as 'http://myhost.com:8080' or 'https://myhost.com:8443'

basicAuthent - Basic Authent in Base64 format to connect to REST API if any (Basic authentication from 'username:paswwd') (nullable)

token - access token (Bearer Token authorization by Header) (nullable)

apiKey - API Key (Base64 of 'apiId:apiKey') (ApiKey authorization by Header) (nullable)

endpoint - as '/waarpr66monitor' or simply '/'

keepConnection - True to keep the connexion opened, False to release the connexion each time

group - the EventLoopGroup to use

Method Detail

post

public final boolean post(com.fasterxml.jackson.databind.node.ObjectNode monitoredTransfers,
                          org.joda.time.DateTime start,
                          org.joda.time.DateTime stop,
                          String serverId)

Parameters:

monitoredTransfers - the Json objet to push as POST

start - the DateTime for the 'from' interval

stop - the DateTime for the 'to' interval

serverId - the serverId that is sending this monitoring information

Returns:

True if the POST succeeded

isKeepConnection

public final boolean isKeepConnection()

setStatus

public final void setStatus(boolean ok)

close

public final void close()
                 throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException