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

ReconnectingRPCConnection

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

Helper class useful for reconnecting to a Node.

Constructors

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

Types

CurrentState

enum CurrentState : Enum<ReconnectingCordaRPCOps.ReconnectingRPCConnection.CurrentState>

Properties

classLoader

val classLoader: ClassLoader?

gracefulReconnect

val gracefulReconnect: GracefulReconnect

nodeHostAndPorts

val nodeHostAndPorts: List<<Error class: unknown class>>

observersPool

val observersPool: ExecutorService

password

val password: String

proxy

open override val proxy: <Error class: unknown class>

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: <Error class: unknown class>? = null

username

val username: String

Functions

open override fun close()

forceClose

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.

isClosed

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.