eu.javaexperience.electronic.uartbus.rpc.client

Class UartbusRpcClientTools

java.lang.Object

eu.javaexperience.electronic.uartbus.rpc.client.UartbusRpcClientTools

public class UartbusRpcClientTools
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static eu.javaexperience.log.Logger	LOG

Method Summary

Modifier and Type	Method and Description
static UartbusConnection	createApi(eu.javaexperience.rpc.javaclient.JavaRpcParallelClient cli)
static UartbusStreamerEndpoint	openIpEndpoint(String ip, int port, eu.javaexperience.interfaces.simple.publish.SimplePublish1<UartbusConnection> connectionInitializer, boolean reconnect)
static UartbusStreamerEndpoint	openIpEndpoint(String ip, int port, eu.javaexperience.interfaces.simple.publish.SimplePublish1<UartbusConnection> connectionInitializer, int... reconnectRetryDelays)
static eu.javaexperience.rpc.javaclient.JavaRpcParallelClient	openIpParallelClient(String ip, int port)
static <T> eu.javaexperience.interfaces.simple.SimpleGet<T>	waitReconnect(eu.javaexperience.interfaces.simple.SimpleGet<T> get, String entity, int... reconn)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final eu.javaexperience.log.Logger LOG

Method Detail

openIpParallelClient

public static eu.javaexperience.rpc.javaclient.JavaRpcParallelClient openIpParallelClient(String ip,
                                                                                          int port)
                                                                                   throws IOException

Throws:

IOException

createApi

public static UartbusConnection createApi(eu.javaexperience.rpc.javaclient.JavaRpcParallelClient cli)

openIpEndpoint

public static UartbusStreamerEndpoint openIpEndpoint(String ip,
                                                     int port,
                                                     eu.javaexperience.interfaces.simple.publish.SimplePublish1<UartbusConnection> connectionInitializer,
                                                     boolean reconnect)

waitReconnect

public static <T> eu.javaexperience.interfaces.simple.SimpleGet<T> waitReconnect(eu.javaexperience.interfaces.simple.SimpleGet<T> get,
                                                                                 String entity,
                                                                                 int... reconn)

openIpEndpoint

public static UartbusStreamerEndpoint openIpEndpoint(String ip,
                                                     int port,
                                                     eu.javaexperience.interfaces.simple.publish.SimplePublish1<UartbusConnection> connectionInitializer,
                                                     int... reconnectRetryDelays)