Package akka.remote.artery
Interface OutboundContext
-
public interface OutboundContext
INTERNAL API Outbound association API that is used by the stream operators. Separate trait to facilitate testing without real transport.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description akka.remote.artery.AssociationState
associationState()
akka.remote.artery.InboundControlJunction.ControlMessageSubject
controlSubject()
An outbound operator can listen to control messages via this observer subject.boolean
isOrdinaryMessageStreamActive()
UniqueAddress
localAddress()
The local inbound address.void
quarantine(java.lang.String reason)
Address
remoteAddress()
The outbound address for this association.void
sendControl(ControlMessage message)
An inbound operator can send control message, e.g.akka.remote.artery.ArterySettings
settings()
-
-
-
Method Detail
-
associationState
akka.remote.artery.AssociationState associationState()
-
controlSubject
akka.remote.artery.InboundControlJunction.ControlMessageSubject controlSubject()
An outbound operator can listen to control messages via this observer subject.
-
isOrdinaryMessageStreamActive
boolean isOrdinaryMessageStreamActive()
- Returns:
true
if any of the streams are active (not stopped due to idle)
-
localAddress
UniqueAddress localAddress()
The local inbound address.
-
quarantine
void quarantine(java.lang.String reason)
-
remoteAddress
Address remoteAddress()
The outbound address for this association.
-
sendControl
void sendControl(ControlMessage message)
An inbound operator can send control message, e.g. a HandshakeReq, to the remote address of this association. It will be sent over the control sub-channel.
-
settings
akka.remote.artery.ArterySettings settings()
-
-