Package akka.remote.artery
Interface OutboundContext
-
- All Known Implementing Classes:
Association
public interface OutboundContext
The local inbound address.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description AssociationState
associationState()
InboundControlJunction.ControlMessageSubject
controlSubject()
An outbound operator can listen to control messages via this observer subject.boolean
isOrdinaryMessageStreamActive()
UniqueAddress
localAddress()
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.ArterySettings
settings()
-
-
-
Method Detail
-
associationState
AssociationState associationState()
-
controlSubject
InboundControlJunction.ControlMessageSubject controlSubject()
An outbound operator can listen to control messages via this observer subject.- Returns:
- (undocumented)
-
isOrdinaryMessageStreamActive
boolean isOrdinaryMessageStreamActive()
- Returns:
true
if any of the streams are active (not stopped due to idle)
-
localAddress
UniqueAddress localAddress()
-
quarantine
void quarantine(java.lang.String reason)
-
remoteAddress
Address remoteAddress()
The outbound address for this association.- Returns:
- (undocumented)
-
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.- Parameters:
message
- (undocumented)
-
settings
ArterySettings settings()
-
-