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

Modifier and Type

Method

Description

org.apache.pekko.remote.artery.AssociationState

associationState()

org.apache.pekko.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(String reason)

Address

remoteAddress()

The outbound address for this association.

void

sendControl(ControlMessage message)

An inbound operator can send control message, e.g.

org.apache.pekko.remote.artery.ArterySettings

settings()

Method Details
- associationState
  
  org.apache.pekko.remote.artery.AssociationState associationState()
- controlSubject
  
  org.apache.pekko.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(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
  
  org.apache.pekko.remote.artery.ArterySettings settings()