Package akka.remote.artery
Interface InboundContext
-
- All Known Implementing Classes:
ArteryAeronUdpTransport
,ArteryTcpTransport
,ArteryTransport
public interface InboundContext
The local inbound address.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description OptionVal<OutboundContext>
association(long uid)
Lookup the outbound association for a given UID.OutboundContext
association(Address remoteAddress)
Lookup the outbound association for a given address.scala.concurrent.Future<Done>
completeHandshake(UniqueAddress peer)
UniqueAddress
localAddress()
void
sendControl(Address to, ControlMessage message)
An inbound operator can send control message, e.g.ArterySettings
settings()
-
-
-
Method Detail
-
association
OutboundContext association(Address remoteAddress)
Lookup the outbound association for a given address.- Parameters:
remoteAddress
- (undocumented)- Returns:
- (undocumented)
-
association
OptionVal<OutboundContext> association(long uid)
Lookup the outbound association for a given UID. Will returnOptionVal.None
if the UID is unknown, i.e. handshake not completed.- Parameters:
uid
- (undocumented)- Returns:
- (undocumented)
-
completeHandshake
scala.concurrent.Future<Done> completeHandshake(UniqueAddress peer)
-
localAddress
UniqueAddress localAddress()
-
sendControl
void sendControl(Address to, ControlMessage message)
An inbound operator can send control message, e.g. a reply, to the origin address with this method. It will be sent over the control sub-channel.- Parameters:
to
- (undocumented)message
- (undocumented)
-
settings
ArterySettings settings()
-
-