public interface InboundContext
Modifier and Type | Method and Description |
---|---|
OutboundContext |
association(Address remoteAddress)
Lookup the outbound association for a given address.
|
OptionVal<OutboundContext> |
association(long uid)
Lookup the outbound association for a given UID.
|
scala.concurrent.Future<Done> |
completeHandshake(UniqueAddress peer) |
UniqueAddress |
localAddress()
The local inbound address.
|
void |
sendControl(Address to,
ControlMessage message)
An inbound stage can send control message, e.g.
|
ArterySettings |
settings() |
UniqueAddress localAddress()
void sendControl(Address to, ControlMessage message)
to
- (undocumented)message
- (undocumented)OutboundContext association(Address remoteAddress)
remoteAddress
- (undocumented)OptionVal<OutboundContext> association(long uid)
OptionVal.None
if the UID is unknown, i.e.
handshake not completed.uid
- (undocumented)scala.concurrent.Future<Done> completeHandshake(UniqueAddress peer)
ArterySettings settings()