docs/net.corda.client.rpc.internal/ReconnectingCordaRPCOps/ReconnectingRPCConnection

ReconnectingRPCConnection

data class ReconnectingRPCConnection(val nodeHostAndPorts: List<NetworkHostAndPort>, val username: String, val password: String, val rpcConfiguration: CordaRPCClientConfiguration, val sslConfiguration: ClientRpcSslOptions? = null, val classLoader: ClassLoader?, val gracefulReconnect: GracefulReconnect = GracefulReconnect(), val observersPool: ExecutorService) : RPCConnection<CordaRPCOps>

Helper class useful for reconnecting to a Node.

Constructors

ReconnectingRPCConnection

constructor(nodeHostAndPorts: List<NetworkHostAndPort>, username: String, password: String, rpcConfiguration: CordaRPCClientConfiguration, sslConfiguration: ClientRpcSslOptions? = null, classLoader: ClassLoader?, gracefulReconnect: GracefulReconnect = GracefulReconnect(), observersPool: ExecutorService)

Types

enum CurrentState : Enum<ReconnectingCordaRPCOps.ReconnectingRPCConnection.CurrentState>

Properties

val classLoader: ClassLoader?

gracefulReconnect

val gracefulReconnect: GracefulReconnect

nodeHostAndPorts

val nodeHostAndPorts: List<NetworkHostAndPort>

val observersPool: ExecutorService

val password: String

open override val proxy: CordaRPCOps

Holds a synthetic class that automatically forwards method calls to the server, and returns the response.

rpcConfiguration

val rpcConfiguration: CordaRPCClientConfiguration

serverProtocolVersion

open override val serverProtocolVersion: Int

The RPC protocol version reported by the server.

sslConfiguration

val sslConfiguration: ClientRpcSslOptions? = null

val username: String

Functions

open override fun close()

open override fun forceClose()

Closes this client without notifying the server.

getTelemetryHandle

open override fun <T> getTelemetryHandle(telemetryClass: Class<T>): T?

Returns the configured openTelemetry global. Returns null if opentelemetry has not been configured.

fun isClosed(): Boolean

notifyServerAndClose

open override fun notifyServerAndClose()

Closes this client gracefully by sending a notification to the server, so it can immediately clean up resources. If the server is not available this method may block for a short period until it's clear the server is not coming back.

reconnectOnError

fun reconnectOnError(e: Throwable)

Called on external error. Will block until the connection is established again.