Package akka.remote.artery
Interface OutboundContext
- 
public interface OutboundContextINTERNAL 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.AssociationStateassociationState()akka.remote.artery.InboundControlJunction.ControlMessageSubjectcontrolSubject()An outbound operator can listen to control messages via this observer subject.booleanisOrdinaryMessageStreamActive()UniqueAddresslocalAddress()The local inbound address.voidquarantine(java.lang.String reason)AddressremoteAddress()The outbound address for this association.voidsendControl(ControlMessage message)An inbound operator can send control message, e.g.akka.remote.artery.ArterySettingssettings() 
 - 
 
- 
- 
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:
 trueif 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()
 
 - 
 
 -