class DomainOutboxQueue extends NamedLogging
The DomainOutboxQueue connects a DomainTopologyManagerX and a DomainOutboxX.
The topology manager enqueues transactions that the domain outbox will pick up and send
to the domain to be sequenced and distributed to the nodes in the domain.
On the one hand, com.digitalasset.canton.topology.DomainOutboxQueue#enqueue may be called at any point to add more topology transactions to the queue. On the other hand, each invocation of com.digitalasset.canton.topology.DomainOutboxQueue#dequeue must be followed by either com.digitalasset.canton.topology.DomainOutboxQueue#requeue or com.digitalasset.canton.topology.DomainOutboxQueue#completeCycle, before com.digitalasset.canton.topology.DomainOutboxQueue#dequeue is called again.
- Alphabetic
- By Inheritance
- DomainOutboxQueue
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DomainOutboxQueue(loggerFactory: NamedLoggerFactory)
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()
- def completeCycle(): Unit
Clears the currently pending transactions.
- def dequeue(limit: Int): Seq[GenericSignedTopologyTransactionX]
Marks up to
limittransactions as pending and returns those transactions.Marks up to
limittransactions as pending and returns those transactions.- limit
batch size
- returns
the topology transactions that have been marked as pending.
- def enqueue(txs: Seq[GenericSignedTopologyTransactionX])(implicit traceContext: TraceContext): Unit
To be called by the topology manager whenever new topology transactions have been validated.
- 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
- Definition Classes
- DomainOutboxQueue → 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 requeue(): Unit
Marks the currently pending transactions as unsent and adds them to the front of the queue in the same order.
- def size(): Int
- 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])