Package io.openems.edge.bridge.http

Class BridgeHttpImpl

java.lang.Object

io.openems.edge.bridge.http.BridgeHttpImpl

All Implemented Interfaces:

BridgeHttp, BridgeHttpCycle, BridgeHttpTime

public class BridgeHttpImpl
extends Object
implements BridgeHttp

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BridgeHttpImpl.CycleEndpointCountdown
static class	BridgeHttpImpl.TimeEndpointCountdown

Nested classes/interfaces inherited from interface io.openems.edge.bridge.http.api.BridgeHttp

BridgeHttp.Endpoint

Nested classes/interfaces inherited from interface io.openems.edge.bridge.http.api.BridgeHttpCycle

BridgeHttpCycle.CycleEndpoint

Nested classes/interfaces inherited from interface io.openems.edge.bridge.http.api.BridgeHttpTime

BridgeHttpTime.TimeEndpoint

Field Summary

Fields inherited from interface io.openems.edge.bridge.http.api.BridgeHttp

DEFAULT_CONNECT_TIMEOUT, DEFAULT_READ_TIMEOUT, EMPTY_ERROR_HANDLER

Constructor Summary

Constructors

Constructor	Description
BridgeHttpImpl()

Method Summary

Modifier and Type	Method	Description
void	activate()	Activate method.
void	deactivate()	Deactivate method.
PriorityQueue<BridgeHttpImpl.CycleEndpointCountdown>	getCycleEndpoints()
Set<BridgeHttpImpl.TimeEndpointCountdown>	getTimeEndpoints()
CompletableFuture<String>	request(BridgeHttp.Endpoint endpoint)	Fetches the url once.
void	subscribeCycle(BridgeHttpCycle.CycleEndpoint endpoint)	Subscribes to one http endpoint.
void	subscribeTime(BridgeHttpTime.TimeEndpoint endpoint)	Subscribes to an BridgeHttpTime.TimeEndpoint.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.openems.edge.bridge.http.api.BridgeHttp

delete, deleteJson, get, getJson, post, postJson, put, putJson, requestJson

Methods inherited from interface io.openems.edge.bridge.http.api.BridgeHttpCycle

subscribeCycle, subscribeCycle, subscribeCycle, subscribeEveryCycle, subscribeEveryCycle, subscribeEveryCycle, subscribeJsonCycle, subscribeJsonCycle, subscribeJsonEveryCycle, subscribeJsonEveryCycle

Methods inherited from interface io.openems.edge.bridge.http.api.BridgeHttpTime

subscribeJsonTime, subscribeJsonTime, subscribeTime, subscribeTime, subscribeTime, subscribeTime, subscribeTime

Constructor Details

BridgeHttpImpl

public BridgeHttpImpl()

Method Details

activate

public void activate()

Activate method.

deactivate

public void deactivate()

Deactivate method.

subscribeCycle

public void subscribeCycle(BridgeHttpCycle.CycleEndpoint endpoint)

Description copied from interface: BridgeHttpCycle

Subscribes to one http endpoint.

Specified by:

subscribeCycle in interface BridgeHttpCycle

Parameters:

endpoint - the BridgeHttpCycle.CycleEndpoint configuration

subscribeTime

public void subscribeTime(BridgeHttpTime.TimeEndpoint endpoint)

Description copied from interface: BridgeHttpTime

Subscribes to an BridgeHttpTime.TimeEndpoint. The BridgeHttpTime.TimeEndpoint.endpoint gets fetched based on the delayed time provided by the BridgeHttpTime.TimeEndpoint.delayTimeProvider. After the endpoint gets fetched either the BridgeHttpTime.TimeEndpoint.onResult or the BridgeHttpTime.TimeEndpoint.onError gets executed depending on the result.

Specified by:

subscribeTime in interface BridgeHttpTime

Parameters:

endpoint - the BridgeHttpTime.TimeEndpoint to add a subscription

request

public CompletableFuture<String> request(BridgeHttp.Endpoint endpoint)

Description copied from interface: BridgeHttp

Fetches the url once.

Specified by:

request in interface BridgeHttp

Parameters:

endpoint - the BridgeHttp.Endpoint to fetch

Returns:

the result response future

getCycleEndpoints

public PriorityQueue<BridgeHttpImpl.CycleEndpointCountdown> getCycleEndpoints()

getTimeEndpoints

public Set<BridgeHttpImpl.TimeEndpointCountdown> getTimeEndpoints()