- java.lang.Object
-
- swim.system.AbstractWarpRef
-
- swim.system.AbstractTierBinding
-
- swim.remote.RemoteHost
-
- swim.remote.RemoteHostClient
-
- All Implemented Interfaces:
DownlinkFactory
,WarpRef
,StayContext
,WarpSocket
,CellBinding
,CellContext
,HostBinding
,TierBinding
,Log
public class RemoteHostClient extends RemoteHost
-
-
Field Summary
-
Fields inherited from class swim.remote.RemoteHost
hostContext, warpSocketContext
-
Fields inherited from class swim.system.AbstractTierBinding
CLOSED_PHASE, CLOSED_STATE, CLOSING_STATE, FAILED_STATE, FAILING_STATE, LOADED_PHASE, LOADED_STATE, LOADING_STATE, OPENED_PHASE, OPENED_STATE, OPENING_STATE, PHASE_MASK, PHASE_SHIFT, RECOVERING_STATE, STARTED_PHASE, STARTED_STATE, STARTING_STATE, STATE_MASK, status, STATUS, STOPPING_STATE, UNLOADING_STATE
-
-
Constructor Summary
Constructors Constructor Description RemoteHostClient(Uri baseUri, IpInterface endpoint)
RemoteHostClient(Uri baseUri, IpInterface endpoint, WarpSettings warpSettings)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
connect()
protected IpSocketRef
connectHttp(InetSocketAddress remoteAddress, HttpClient client, HttpSettings httpSettings)
protected IpSocketRef
connectHttps(InetSocketAddress remoteAddress, HttpClient client, HttpSettings httpSettings)
void
didConnect()
void
didFail(Throwable error)
protected void
didReadClose(WsCloseFrame<?,?> frame)
protected void
reconnect()
void
setHostContext(HostContext hostContext)
protected void
willOpen()
-
Methods inherited from class swim.remote.RemoteHost
bindDownlink, bottomHost, cellAddress, cipherSuite, closeDownlink, closeDownlinks, closeUplinks, collectProfile, connectUplinks, debug, didBecome, didBecomeMaster, didBecomeSlave, didClose, didCloseDownlink, didCloseUplink, didDisconnect, didOpenDownlink, didOpenUplink, didPushMessage, didRead, didRead, didSecure, didTimeout, didUpdateMetrics, didUpgrade, didWrite, didWrite, disconnectUplinks, doRead, doWrite, edgeName, error, fail, flushMetrics, forbid, getNode, hostContext, hostUri, hostWrapper, idleTimeout, info, isConnected, isMaster, isPrimary, isRemote, isReplica, isSecure, isSlave, localAddress, localCertificates, localIdentity, localPrincipal, meshUri, nodes, onAuthedResponse, onAuthRequest, onCommandMessage, onDeauthedResponse, onDeauthRequest, onEventMessage, onLinkedResponse, onLinkRequest, onSyncedResponse, onSyncRequest, onUnknownEnvelope, onUnlinkedResponse, onUnlinkRequest, openDownlink, openMetaDownlink, openMetaHost, openMetaLane, openMetaLanes, openMetaNode, openMetaUplink, openNode, openNode, openReflectLanes, openUplink, openWarpUplink, part, partKey, policy, pushDown, pushUp, reconcileReceiveBacklog, remoteAddress, remoteCertificates, remoteIdentity, remotePrincipal, reportDown, reportMetrics, resolve, routeDownlink, routeUplink, schedule, securityProtocol, setPrimary, setReplica, setWarpSocketContext, stage, store, tierContext, trace, unwrapHost, warn, warpSocketContext, willBecome, willClose, willConnect, willPushMessage, willSecure
-
Methods inherited from class swim.system.AbstractTierBinding
activate, awaitStart, close, didLoad, didOpen, didStart, didStop, didUnload, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload, willLoad, willStart, willStop, willUnload
-
Methods inherited from class swim.system.AbstractWarpRef
command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, downlink, downlinkHttp, downlinkList, downlinkMap, downlinkValue, downlinkWs, hostRef, hostRef, laneRef, laneRef, laneRef, laneRef, nodeRef, nodeRef, nodeRef, nodeRef
-
-
-
-
Constructor Detail
-
RemoteHostClient
public RemoteHostClient(Uri baseUri, IpInterface endpoint, WarpSettings warpSettings)
-
RemoteHostClient
public RemoteHostClient(Uri baseUri, IpInterface endpoint)
-
-
Method Detail
-
setHostContext
public void setHostContext(HostContext hostContext)
- Specified by:
setHostContext
in interfaceHostBinding
- Overrides:
setHostContext
in classRemoteHost
-
connect
public void connect()
-
connectHttp
protected IpSocketRef connectHttp(InetSocketAddress remoteAddress, HttpClient client, HttpSettings httpSettings)
-
connectHttps
protected IpSocketRef connectHttps(InetSocketAddress remoteAddress, HttpClient client, HttpSettings httpSettings)
-
reconnect
protected void reconnect()
- Overrides:
reconnect
in classRemoteHost
-
didConnect
public void didConnect()
- Specified by:
didConnect
in interfaceWarpSocket
- Overrides:
didConnect
in classRemoteHost
-
willOpen
protected void willOpen()
- Overrides:
willOpen
in classAbstractTierBinding
-
didReadClose
protected void didReadClose(WsCloseFrame<?,?> frame)
- Overrides:
didReadClose
in classRemoteHost
-
didFail
public void didFail(Throwable error)
- Specified by:
didFail
in interfaceTierBinding
- Specified by:
didFail
in interfaceWarpSocket
- Overrides:
didFail
in classRemoteHost
-
-