Packages

c

akka.stream

InvalidPartnerActorException

final case class InvalidPartnerActorException(expectedRef: ActorRef, gotRef: ActorRef, msg: String) extends IllegalStateException with Product with Serializable

Stream refs establish a connection between a local and remote actor, representing the origin and remote sides of a stream. Each such actor refers to the other side as its "partner". We make sure that no other actor than the initial partner can send demand/messages to the other side accidentally.

This exception is thrown when a message is received from a non-partner actor, which could mean a bug or some actively malicient behavior from the other side.

This is not meant as a security feature, but rather as plain sanity-check.

Source
StreamRefs.scala
Linear Supertypes
Serializable, Product, Equals, IllegalStateException, RuntimeException, Exception, Throwable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. InvalidPartnerActorException
  2. Serializable
  3. Product
  4. Equals
  5. IllegalStateException
  6. RuntimeException
  7. Exception
  8. Throwable
  9. Serializable
  10. AnyRef
  11. Any
Implicitly
  1. by RichException
  2. by any2stringadd
  3. by StringFormat
  4. by Ensuring
  5. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new InvalidPartnerActorException(expectedRef: ActorRef, gotRef: ActorRef, msg: String)

Value Members

  1. final def addSuppressed(arg0: Throwable): Unit
    Definition Classes
    Throwable
  2. val expectedRef: ActorRef
  3. def fillInStackTrace(): Throwable
    Definition Classes
    Throwable
  4. def getCause(): Throwable
    Definition Classes
    Throwable
  5. def getLocalizedMessage(): String
    Definition Classes
    Throwable
  6. def getMessage(): String
    Definition Classes
    Throwable
  7. def getStackTrace(): Array[StackTraceElement]
    Definition Classes
    Throwable
  8. final def getSuppressed(): Array[Throwable]
    Definition Classes
    Throwable
  9. val gotRef: ActorRef
  10. def initCause(arg0: Throwable): Throwable
    Definition Classes
    Throwable
  11. val msg: String
  12. def printStackTrace(arg0: PrintWriter): Unit
    Definition Classes
    Throwable
  13. def printStackTrace(arg0: PrintStream): Unit
    Definition Classes
    Throwable
  14. def printStackTrace(): Unit
    Definition Classes
    Throwable
  15. def setStackTrace(arg0: Array[StackTraceElement]): Unit
    Definition Classes
    Throwable
  16. def toString(): String
    Definition Classes
    Throwable → AnyRef → Any

Deprecated Value Members

  1. def getStackTraceString: String
    Implicit
    This member is added by an implicit conversion from InvalidPartnerActorException to RichException performed by method RichException in scala.Predef.
    Definition Classes
    RichException
    Annotations
    @deprecated
    Deprecated

    (Since version 2.11.0) use Throwable#getStackTrace