akka.remote.artery

Interface OutboundContext

All Known Implementing Classes:

Association

public interface OutboundContext

INTERNAL API Outbound association API that is used by the stream stages. Separate trait to facilitate testing without real transport.

Method Summary

Modifier and Type	Method and Description
AssociationState	associationState()
InboundControlJunction.ControlMessageSubject	controlSubject() An outbound stage can listen to control messages via this observer subject.
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 stage can send control message, e.g.
ArterySettings	settings()

Method Detail

localAddress

UniqueAddress localAddress()

The local inbound address.

Returns:

(undocumented)

remoteAddress

Address remoteAddress()

The outbound address for this association.

Returns:

(undocumented)

associationState

AssociationState associationState()

quarantine

void quarantine(java.lang.String reason)

sendControl

void sendControl(ControlMessage message)

An inbound stage 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)

controlSubject

InboundControlJunction.ControlMessageSubject controlSubject()

An outbound stage can listen to control messages via this observer subject.

Returns:

(undocumented)

settings

ArterySettings settings()