public abstract class EndpointActor extends java.lang.Object implements Actor, ActorLogging
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
EndpointActor(Address localAddress,
Address remoteAddress,
Transport transport,
RemoteSettings settings,
AkkaPduCodec codec) |
Modifier and Type | Method and Description |
---|---|
AkkaPduCodec |
codec() |
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
EventPublisher |
eventPublisher() |
abstract boolean |
inbound() |
Address |
localAddress() |
void |
publishDisassociated() |
void |
publishError(java.lang.Throwable reason,
Logging.LogLevel logLevel) |
Address |
remoteAddress() |
ActorRef |
self()
The 'self' field holds the ActorRef for this actor.
|
RemoteSettings |
settings() |
Transport |
transport() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preRestart, preStart, receive, sender, supervisorStrategy, unhandled
log
public EndpointActor(Address localAddress, Address remoteAddress, Transport transport, RemoteSettings settings, AkkaPduCodec codec)
public ActorContext context()
Actor
forward
.
WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API. getContext
returns a
UntypedActorContext
, which is the Java API of the actor
context.
public final ActorRef self()
Actor
self ! message
public Address localAddress()
public Address remoteAddress()
public Transport transport()
public RemoteSettings settings()
public AkkaPduCodec codec()
public abstract boolean inbound()
public EventPublisher eventPublisher()
public void publishError(java.lang.Throwable reason, Logging.LogLevel logLevel)
public void publishDisassociated()