com.digitalasset.canton.sequencing.client
SubscriptionCloseReason
Companion trait SubscriptionCloseReason
object SubscriptionCloseReason
- Alphabetic
- By Inheritance
- SubscriptionCloseReason
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class HandlerError[E](error: E) extends SubscriptionCloseReason[E] with Product with Serializable
- final case class HandlerException(exception: Throwable) extends SubscriptionCloseReason[Nothing] with Product with Serializable
The handler threw an exception
- trait PermissionDeniedError extends SubscriptionCloseReason[Nothing]
The subscription was denied Implementations are expected to provide their own error of this type
- trait SubscriptionError extends SubscriptionCloseReason[Nothing]
The subscription itself failed.
The subscription itself failed. transports.SequencerClientTransport implementations are expected to provide their own hierarchy of errors and supply a matching SubscriptionErrorRetryPolicy to the SequencerClient for determining which errors are appropriate for attempting to resume a subscription.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- case object Closed extends SubscriptionCloseReason[Nothing] with Product with Serializable
The subscription was closed by the client.
- case object Shutdown extends SubscriptionCloseReason[Nothing] with Product with Serializable
The subscription was closed due to an ongoing shutdown procedure.
- case object TransportChange extends SubscriptionCloseReason[Nothing] with Product with Serializable
The sequencer connection details are being updated, so the subscription is being closed so another one is created with the updated transport.
The sequencer connection details are being updated, so the subscription is being closed so another one is created with the updated transport. This is not an error and also not a reason to close the sequencer client.