Package io.openems.common.websocket

Class ClientReconnectorWorker

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.common.websocket.ClientReconnectorWorker

public class ClientReconnectorWorker
extends AbstractWorker

Field Summary

Fields inherited from class io.openems.common.worker.AbstractWorker

ALWAYS_WAIT_FOR_TRIGGER_NEXT_RUN, DO_NOT_WAIT, thread

Constructor Summary

Constructors

Constructor	Description
ClientReconnectorWorker(AbstractWebsocketClient<?> parent)

Method Summary

Modifier and Type	Method	Description
protected void	forever()	This method is called in a loop forever until the Thread gets interrupted.
protected int	getCycleTime()	Gets the cycleTime of this worker in [ms].
protected static <T extends WsData> void	resetWebSocketClient(org.java_websocket.client.WebSocketClient ws, Supplier<T> attachmentSupplier)	This method is a copy of WebSocketClient reset()-method, because the original one may block at the call of 'closeBlocking()' method.

Methods inherited from class io.openems.common.worker.AbstractWorker

activate, activate, deactivate, modified, modified, setPriority, triggerNextRun

Methods inherited from class java.lang.Object

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

Constructor Details

ClientReconnectorWorker

public ClientReconnectorWorker(AbstractWebsocketClient<?> parent)

Method Details

forever

protected void forever()
                throws Exception

Description copied from class: AbstractWorker

This method is called in a loop forever until the Thread gets interrupted.

Specified by:

forever in class AbstractWorker

Throws:

Exception

resetWebSocketClient

protected static <T extends WsData> void resetWebSocketClient(org.java_websocket.client.WebSocketClient ws,
 Supplier<T> attachmentSupplier)
                                                       throws Exception

This method is a copy of WebSocketClient reset()-method, because the original one may block at the call of 'closeBlocking()' method. It also sets the new attachment from the attachment supplier.

Waiting for https://github.com/TooTallNate/Java-WebSocket/pull/1251 to be merged.

Type Parameters:

T - the type of the attachment

Parameters:

ws - the WebSocketClient

attachmentSupplier - the supplier for the new attachment

Throws:

Exception - on error

getCycleTime

protected int getCycleTime()

Description copied from class: AbstractWorker

Gets the cycleTime of this worker in [ms].

• > 0 sets the minimum execution time of one Cycle
• = 0 never wait between two consecutive executions of forever()
• < 0 causes the Cycle to sleep forever until 'triggerNextRun()' is called

Specified by:

getCycleTime in class AbstractWorker

Returns:

the cycleTime