akka.remote
Class EndpointActor

java.lang.Object
  extended by akka.remote.EndpointActor
All Implemented Interfaces:
Actor, ActorLogging
Direct Known Subclasses:
EndpointReader, EndpointWriter

public abstract class EndpointActor
extends java.lang.Object
implements Actor, ActorLogging

INTERNAL API


Nested Class Summary
 
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$
 
Constructor Summary
EndpointActor(Address localAddress, Address remoteAddress, Transport transport, RemoteSettings settings, AkkaPduCodec codec)
           
 
Method Summary
 AkkaPduCodec codec()
           
 EventPublisher eventPublisher()
           
abstract  boolean inbound()
           
 Address localAddress()
           
 void publishDisassociated()
           
 void publishError(java.lang.Throwable reason, Logging.LogLevel logLevel)
           
 Address remoteAddress()
           
 RemoteSettings settings()
           
 Transport transport()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
 
Methods inherited from interface akka.actor.ActorLogging
_log, log
 

Constructor Detail

EndpointActor

public EndpointActor(Address localAddress,
                     Address remoteAddress,
                     Transport transport,
                     RemoteSettings settings,
                     AkkaPduCodec codec)
Method Detail

localAddress

public Address localAddress()

remoteAddress

public Address remoteAddress()

transport

public Transport transport()

settings

public RemoteSettings settings()

codec

public AkkaPduCodec codec()

inbound

public abstract boolean inbound()

eventPublisher

public EventPublisher eventPublisher()

publishError

public void publishError(java.lang.Throwable reason,
                         Logging.LogLevel logLevel)

publishDisassociated

public void publishDisassociated()