- java.lang.Object
-
- swim.system.AbstractUplinkContext
-
- swim.system.warp.WarpUplinkModem
-
- swim.system.warp.SupplyUplinkModem
-
- All Implemented Interfaces:
Link
,Uplink
,WarpLink
,WarpUplink
,Observable<Object>
,LinkContext
,WarpContext
,Log
- Direct Known Subclasses:
CommandLaneUplink
,SupplyLaneUplink
public abstract class SupplyUplinkModem extends WarpUplinkModem
-
-
Field Summary
-
Fields inherited from class swim.system.warp.WarpUplinkModem
linkBinding, status, uplinkAddress
-
Fields inherited from class swim.system.AbstractUplinkContext
observers
-
-
Constructor Summary
Constructors Constructor Description SupplyUplinkModem(WarpBinding linkBinding, UplinkAddress uplinkAddress)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
downQueueIsEmpty()
protected Value
nextDownQueue()
void
queueDown(Value body)
-
Methods inherited from class swim.system.warp.WarpUplinkModem
body, cellAddressUp, collectProfile, cueDown, cueUp, didClose, didClose, didLink, didSync, didUnlink, didUpdateMetrics, dispatchDidClose, dispatchOnCommand, dispatchOnEvent, dispatchOnLink, dispatchOnLinked, dispatchOnSync, dispatchOnSynced, dispatchOnUnlink, dispatchOnUnlinked, feedUp, flushMetrics, hostUri, laneUri, linkBinding, linkedResponse, linkKey, linkWrapper, nextDownCue, nextDownCueEvent, nextDownQueueEvent, nodeUri, observe, onCommand, onCommand, onEvent, onEvent, onLink, onLinked, onSync, onSynced, onUnlink, onUnlinked, openMetaUplink, prio, pullDown, pullDownEnvelope, pullDownEvent, pullDownLinked, pullDownSynced, pullDownUnlinked, pushDown, pushUp, pushUpCommand, pushUpLink, pushUpSync, pushUpUnknown, pushUpUnlink, rate, reportMetrics, runOnCommand, runOnLink, runOnSync, runOnUnlink, runPullDown, sendDown, skipUp, syncedResponse, unlink, unlinkedResponse, unobserve, willLink, willSync, willUnlink
-
Methods inherited from class swim.system.AbstractUplinkContext
bottomLink, cipherSuite, cipherSuiteUp, close, closeUp, debug, debugUp, didCloseDown, didFail, didFailDown, didOpenDown, error, errorUp, fail, failUp, info, infoUp, isConnected, isConnectedUp, isRemote, isRemoteUp, isSecure, isSecureUp, laneBinding, localAddress, localAddressUp, localCertificates, localCertificatesUp, localIdentity, localIdentityUp, localPrincipal, localPrincipalUp, remoteAddress, remoteAddressUp, remoteCertificates, remoteCertificatesUp, remoteIdentity, remoteIdentityUp, remotePrincipal, remotePrincipalUp, securityProtocol, securityProtocolUp, stage, trace, traceUp, unwrapLink, warn, warnUp
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface swim.api.Link
cipherSuite, close, isConnected, isRemote, isSecure, localAddress, localCertificates, localIdentity, localPrincipal, remoteAddress, remoteCertificates, remoteIdentity, remotePrincipal, securityProtocol
-
Methods inherited from interface swim.system.LinkContext
bottomLink, cipherSuiteUp, closeUp, debugUp, didCloseDown, didFailDown, didOpenDown, errorUp, failUp, infoUp, isConnectedUp, isRemoteUp, isSecureUp, localAddressUp, localCertificatesUp, localIdentityUp, localPrincipalUp, remoteAddressUp, remoteCertificatesUp, remoteIdentityUp, remotePrincipalUp, securityProtocolUp, traceUp, unwrapLink, warnUp
-
-
-
-
Constructor Detail
-
SupplyUplinkModem
public SupplyUplinkModem(WarpBinding linkBinding, UplinkAddress uplinkAddress)
-
-
Method Detail
-
downQueueIsEmpty
protected boolean downQueueIsEmpty()
- Overrides:
downQueueIsEmpty
in classWarpUplinkModem
-
queueDown
public void queueDown(Value body)
- Overrides:
queueDown
in classWarpUplinkModem
-
nextDownQueue
protected Value nextDownQueue()
- Overrides:
nextDownQueue
in classWarpUplinkModem
-
-