com.prosysopc.ua.server

Class ReverseConnectionParameters.Builder

java.lang.Object

com.prosysopc.ua.server.ReverseConnectionParameters.Builder

Enclosing class:

ReverseConnectionParameters

public static class ReverseConnectionParameters.Builder
extends Object

Builder for ReverseConnectionParameters.

Method Summary

Modifier and Type	Method and Description
ReverseConnectionParameters	build()
String	getClientServerEndpointUrl() See ReverseConnectionParameters.getClientServerEndpointUrl().
String	getEndpointUrlForClientConnection() See ReverseConnectionParameters.getEndpointUrlForClientConnection().
Function<List<String>,String>	getEndpointUrlForClientConnectionSelector() See setEndpointUrlForClientConnectionSelector(Function).
List<Integer>	getRetryWaitIntervals() List of wait times for retry.
ReverseConnectionParameters.Builder	setClientServerEndpointUrl(String clientServerEndpointUrl) See ReverseConnectionParameters.getClientServerEndpointUrl().
ReverseConnectionParameters.Builder	setEndpointUrlForClientConnection(String endpointUrlForClientConnection) See ReverseConnectionParameters.getEndpointUrlForClientConnection().
void	setEndpointUrlForClientConnectionSelector(Function<List<String>,String> endpointUrlForClientConnectionSelector) If the given setEndpointUrlForClientConnection(String) is null, and the server has more than one EndpointUrl, this Function is used to determine which one of them is sent to the client.
ReverseConnectionParameters.Builder	setStatusListener(Executor executor, Consumer<ReverseConnectionStatus> consumer) Sets a "status listener" for the reverse connection.

Methods inherited from class java.lang.Object

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

Method Detail

build

public ReverseConnectionParameters build()

getClientServerEndpointUrl

public String getClientServerEndpointUrl()

See ReverseConnectionParameters.getClientServerEndpointUrl().

getEndpointUrlForClientConnection

public String getEndpointUrlForClientConnection()

See ReverseConnectionParameters.getEndpointUrlForClientConnection().

getEndpointUrlForClientConnectionSelector

public Function<List<String>,String> getEndpointUrlForClientConnectionSelector()

See setEndpointUrlForClientConnectionSelector(Function).

getRetryWaitIntervals

public List<Integer> getRetryWaitIntervals()

List of wait times for retry. The first retry attempt will wait the first index (0) in milliseconds, the second one the second etc. The last entry in the list is used for retry attempts outside of the list indexes. By default the list contains elements: 100, 500, 1000.

setClientServerEndpointUrl

public ReverseConnectionParameters.Builder setClientServerEndpointUrl(String clientServerEndpointUrl)

See ReverseConnectionParameters.getClientServerEndpointUrl().

setEndpointUrlForClientConnection

public ReverseConnectionParameters.Builder setEndpointUrlForClientConnection(String endpointUrlForClientConnection)

See ReverseConnectionParameters.getEndpointUrlForClientConnection().

setEndpointUrlForClientConnectionSelector

public void setEndpointUrlForClientConnectionSelector(Function<List<String>,String> endpointUrlForClientConnectionSelector)

If the given setEndpointUrlForClientConnection(String) is null, and the server has more than one EndpointUrl, this Function is used to determine which one of them is sent to the client. The default implementation returns the index 0.

setStatusListener

public ReverseConnectionParameters.Builder setStatusListener(Executor executor,
                                                             Consumer<ReverseConnectionStatus> consumer)

Sets a "status listener" for the reverse connection. The given Consumer is called on the given Executor whenever the status of the connection changes. IMPORTANT! the idea here is to give an Executor that enforces that the listener doesn't exec concurrently (such as Executors.newSingleThreadExecutor().