class TimelyRejectNotifier extends NamedLogging
- Alphabetic
- By Inheritance
- TimelyRejectNotifier
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new TimelyRejectNotifier(rejecter: TimelyRejecter, initialUpperBound: Option[CantonTimestamp], loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)
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() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- TimelyRejectNotifier → NamedLogging
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def notifyAsync(tracedCleanSequencerCounterPrehead: Traced[SequencerCounterCursorPrehead]): Unit
Notifies the in-flight submission tracker that the clean sequencer counter prehead has advanced to the given point.
Notifies the in-flight submission tracker that the clean sequencer counter prehead has advanced to the given point. Does nothing if a notification with a higher timestamp has already happened or is happening concurrently.
The method returns immediately after the notification has been scheduled. The notification itself happens asynchronously in a spawned future.
- def notifyIfInPastAsync(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Boolean
Notifies the in-flight submission tracker again if it may have already been notified for the given timestamp or later.
Notifies the in-flight submission tracker again if it may have already been notified for the given timestamp or later. Does nothing if the in-flight submission tracker has not yet been notified of the given timestamp or any later timestamp.
The method returns immediately after the notification has been scheduled. The notification itself happens asynchronously in a spawned future.
When a timely rejection's timestamp has been back-dated to the sequencing timestamp of an already processed message, a call to this method ensures that the rejection will be emitted even if no further messages are processed from the domain.
- 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])