akka.stream

Class AbruptTerminationException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

akka.stream.AbruptTerminationException

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product, scala.util.control.NoStackTrace

public final class AbruptTerminationException
extends java.lang.RuntimeException
implements scala.util.control.NoStackTrace, scala.Product, scala.Serializable

This exception signals that an actor implementing a Reactive Streams Subscriber, Publisher or Processor has been terminated without being notified by an onError, onComplete or cancel signal. This usually happens when an ActorSystem is shut down while stream processing actors are still running.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbruptTerminationException(ActorRef actor)

Method Summary

Modifier and Type	Method and Description
ActorRef	actor()
static void	addSuppressed(java.lang.Throwable x$1)
abstract static boolean	canEqual(java.lang.Object that)
abstract static boolean	equals(java.lang.Object that)
static java.lang.Throwable	fillInStackTrace()
static java.lang.Throwable	getCause()
static java.lang.String	getLocalizedMessage()
static java.lang.String	getMessage()
static java.lang.StackTraceElement[]	getStackTrace()
static int	getStackTraceDepth()
static java.lang.StackTraceElement	getStackTraceElement(int x$1)
static java.lang.Throwable[]	getSuppressed()
static java.lang.Throwable	initCause(java.lang.Throwable x$1)
static void	printStackTrace()
static void	printStackTrace(java.io.PrintStream x$1)
static void	printStackTrace(java.io.PrintWriter x$1)
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
static void	setStackTrace(java.lang.StackTraceElement[] x$1)
static java.lang.String	toString()

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.util.control.NoStackTrace

$init$, fillInStackTrace, noSuppression

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

AbruptTerminationException

public AbruptTerminationException(ActorRef actor)

Method Detail

getMessage

public static java.lang.String getMessage()

getLocalizedMessage

public static java.lang.String getLocalizedMessage()

getCause

public static java.lang.Throwable getCause()

initCause

public static java.lang.Throwable initCause(java.lang.Throwable x$1)

toString

public static java.lang.String toString()

printStackTrace

public static void printStackTrace()

printStackTrace

public static void printStackTrace(java.io.PrintStream x$1)

printStackTrace

public static void printStackTrace(java.io.PrintWriter x$1)

getStackTrace

public static java.lang.StackTraceElement[] getStackTrace()

setStackTrace

public static void setStackTrace(java.lang.StackTraceElement[] x$1)

getStackTraceDepth

public static int getStackTraceDepth()

getStackTraceElement

public static java.lang.StackTraceElement getStackTraceElement(int x$1)

addSuppressed

public static final void addSuppressed(java.lang.Throwable x$1)

getSuppressed

public static final java.lang.Throwable[] getSuppressed()

fillInStackTrace

public static java.lang.Throwable fillInStackTrace()

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

actor

public ActorRef actor()