class DefaultMediatorEventDeduplicator extends MediatorEventDeduplicator with NamedLogging
- Alphabetic
- By Inheritance
- DefaultMediatorEventDeduplicator
- NamedLogging
- MediatorEventDeduplicator
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DefaultMediatorEventDeduplicator(state: MediatorState, verdictSender: VerdictSender, getDeduplicationTimeout: (Traced[CantonTimestamp]) => FutureUnlessShutdown[Duration], getDecisionTime: (Traced[CantonTimestamp]) => FutureUnlessShutdown[CantonTimestamp], protocolVersion: ProtocolVersion, loggerFactory: NamedLoggerFactory)(implicit executionContext: 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]) @IntrinsicCandidate() @native()
- 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
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- DefaultMediatorEventDeduplicator → 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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def rejectDuplicate(requestTimestamp: CantonTimestamp, confirmationRequest: MediatorConfirmationRequest, envelopes: Seq[DefaultOpenEnvelope])(implicit traceContext: TraceContext, callerCloseoContext: CloseContext): FutureUnlessShutdown[(Boolean, FutureUnlessShutdown[Unit])]
If the uuid of the confirmation request has been used previously and the previous usage has not expired by the sequencer timestamp of the corresponding event, then the event is rejected through the sequencer client.
If the uuid of the confirmation request has been used previously and the previous usage has not expired by the sequencer timestamp of the corresponding event, then the event is rejected through the sequencer client. If the uuid of an envelope is fresh, it will be stored as being "in use".
- returns
(isUnique, storeF):isUniqueistrue, if the confirmation request was considered to be unique and its UUID doesn't clash with previously processed confirmation requests. Conversely, it isfalseif the confirmation request is considered to be a duplicate submission.storeFcompletes when the persistent state has been updated and all rejections have been sent. The methodrejectDuplicatemay be invoked again whilestoreFis still running; The event should be considered clean only whenstoreFis completed.
- Definition Classes
- DefaultMediatorEventDeduplicator → MediatorEventDeduplicator
- 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])