Package co.paralleluniverse.actors

Class ActorImpl<Message>

  • All Implemented Interfaces:
    java.io.Serializable
    Direct Known Subclasses:
    Actor, FakeActor, RemoteActor
    public abstract class ActorImpl<Message>
extends java.lang.Object
implements java.io.Serializable
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected co.paralleluniverse.common.monitoring.FlightRecorder flightRecorder  
      protected ActorRef<Message> ref  

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected ActorImpl​(java.lang.String name, SendPort<java.lang.Object> mailbox, ActorRef<Message> ref)  

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      protected abstract void addLifecycleListener​(co.paralleluniverse.actors.LifecycleListener listener)  
      void close()  
      void close​(java.lang.Throwable t)  
      protected co.paralleluniverse.actors.LifecycleListener getLifecycleListener()  
      SendPort<java.lang.Object> getMailbox()  
      java.lang.String getName()  
      protected abstract void internalSend​(java.lang.Object message)
      For internal use
      protected abstract void internalSendNonSuspendable​(java.lang.Object message)  
      protected abstract void interrupt()  
      protected boolean isRecordingLevel​(int level)  
      protected abstract void linked​(ActorRef actor)  
      protected SendPort<java.lang.Object> mailbox()  
      protected void record​(int level, java.lang.String clazz, java.lang.String method, java.lang.String format)  
      protected void record​(int level, java.lang.String clazz, java.lang.String method, java.lang.String format, java.lang.Object arg1)  
      protected void record​(int level, java.lang.String clazz, java.lang.String method, java.lang.String format, java.lang.Object... args)  
      protected void record​(int level, java.lang.String clazz, java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2)  
      protected void record​(int level, java.lang.String clazz, java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3)  
      protected void record​(int level, java.lang.String clazz, java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4)  
      protected void record​(int level, java.lang.String clazz, java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5)  
      ActorRef<Message> ref()  
      protected abstract void removeLifecycleListener​(co.paralleluniverse.actors.LifecycleListener listener)  
      protected abstract void removeObserverListeners​(ActorRef actor)  
      void sendOrInterrupt​(java.lang.Object message)  
      protected void sendSync​(Message message)  
      protected void setName​(java.lang.String name)  
      protected abstract void throwIn​(java.lang.RuntimeException e)  
      java.lang.String toString()  
      protected abstract boolean trySend​(Message message)  
      protected abstract void unlinked​(ActorRef actor)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    • Field Detail

      • flightRecorder

        protected final transient co.paralleluniverse.common.monitoring.FlightRecorder flightRecorder

    • Constructor Detail

      • ActorImpl

        protected ActorImpl​(java.lang.String name,
                    SendPort<java.lang.Object> mailbox,
                    ActorRef<Message> ref)

    • Method Detail

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object

      • getName

        public java.lang.String getName()

      • setName

        protected void setName​(java.lang.String name)

      • mailbox

        protected SendPort<java.lang.Object> mailbox()

      • getMailbox

        public SendPort<java.lang.Object> getMailbox()

      • sendOrInterrupt

        public void sendOrInterrupt​(java.lang.Object message)

      • close

        public void close()

      • close

        public void close​(java.lang.Throwable t)

      • interrupt

        protected abstract void interrupt()

      • trySend

        protected abstract boolean trySend​(Message message)

      • internalSend

        protected abstract void internalSend​(java.lang.Object message)
                              throws SuspendExecution
        For internal use
        Parameters:
        message -
        Throws:
        SuspendExecution

      • internalSendNonSuspendable

        protected abstract void internalSendNonSuspendable​(java.lang.Object message)

      • throwIn

        protected abstract void throwIn​(java.lang.RuntimeException e)

      • addLifecycleListener

        protected abstract void addLifecycleListener​(co.paralleluniverse.actors.LifecycleListener listener)

      • removeLifecycleListener

        protected abstract void removeLifecycleListener​(co.paralleluniverse.actors.LifecycleListener listener)

      • removeObserverListeners

        protected abstract void removeObserverListeners​(ActorRef actor)

      • linked

        protected abstract void linked​(ActorRef actor)

      • unlinked

        protected abstract void unlinked​(ActorRef actor)

      • getLifecycleListener

        protected co.paralleluniverse.actors.LifecycleListener getLifecycleListener()

      • isRecordingLevel

        protected final boolean isRecordingLevel​(int level)

      • record

        protected final void record​(int level,
                            java.lang.String clazz,
                            java.lang.String method,
                            java.lang.String format)

      • record

        protected final void record​(int level,
                            java.lang.String clazz,
                            java.lang.String method,
                            java.lang.String format,
                            java.lang.Object arg1)

      • record

        protected final void record​(int level,
                            java.lang.String clazz,
                            java.lang.String method,
                            java.lang.String format,
                            java.lang.Object arg1,
                            java.lang.Object arg2)

      • record

        protected final void record​(int level,
                            java.lang.String clazz,
                            java.lang.String method,
                            java.lang.String format,
                            java.lang.Object arg1,
                            java.lang.Object arg2,
                            java.lang.Object arg3)

      • record

        protected final void record​(int level,
                            java.lang.String clazz,
                            java.lang.String method,
                            java.lang.String format,
                            java.lang.Object arg1,
                            java.lang.Object arg2,
                            java.lang.Object arg3,
                            java.lang.Object arg4)

      • record

        protected final void record​(int level,
                            java.lang.String clazz,
                            java.lang.String method,
                            java.lang.String format,
                            java.lang.Object arg1,
                            java.lang.Object arg2,
                            java.lang.Object arg3,
                            java.lang.Object arg4,
                            java.lang.Object arg5)

      • record

        protected final void record​(int level,
                            java.lang.String clazz,
                            java.lang.String method,
                            java.lang.String format,
                            java.lang.Object... args)