More information:

Class SinkClosedException

All Implemented Interfaces:

public class SinkClosedException
extends SinkException

This exception is thrown if one attempts to enqueue a new element onto a sink which is closed. A sink is considered closed when it is no longer being serviced by any application component.

As opposed to SinkClosedEvent, which is pushed when a sink closes asynchronously, SinkClosedException is thrown immediately when attempting to enqueue onto a closed sink.

Matt Welsh
See Also:
SinkClosedEvent, Serialized Form

Constructor Summary
SinkClosedException(java.lang.String s)
Methods inherited from class java.lang.Throwable
fillInStackTrace, getLocalizedMessage, getMessage, printStackTrace, printStackTrace, printStackTrace, toString
Methods inherited from class java.lang.Object
, clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail


public SinkClosedException()


public SinkClosedException(java.lang.String s)

More information: