class RecoveringFutureQueueImpl[T] extends RecoveringFutureQueue[T]
- Annotations
- @SuppressWarnings()
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- RecoveringFutureQueueImpl
- RecoveringFutureQueue
- FutureQueue
- CompletingAndShutdownable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new RecoveringFutureQueueImpl(maxBlockedOffer: Int, bufferSize: Int, loggerFactory: NamedLoggerFactory, retryStategy: (Int) => Long, retryAttemptWarnThreshold: Int, retryAttemptErrorThreshold: Int, uncommittedWarnTreshold: Int, recoveringQueueMetrics: RecoveringQueueMetrics, consumerFactory: (Commit) => Future[FutureQueueConsumer[T]])
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()
- def done: Future[Done]
- returns
successfully after shutdown, or with a failure after aborted internally
- Definition Classes
- RecoveringFutureQueueImpl → CompletingAndShutdownable
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def firstSuccessfulConsumerInitialization: Future[Unit]
- Definition Classes
- RecoveringFutureQueueImpl → RecoveringFutureQueue
- 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
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def offer(elem: T): Future[Done]
Adding elements to the queue.
Adding elements to the queue. The backpressure is implemented with the future result. An implementation may limit how many parallel unfinished futures can be outstanding at any point in time.
- Definition Classes
- RecoveringFutureQueueImpl → FutureQueue
- def shutdown(): Unit
After shutdown is triggered the done Future is expected to terminate successfully
After shutdown is triggered the done Future is expected to terminate successfully
- Definition Classes
- RecoveringFutureQueueImpl → CompletingAndShutdownable
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def uncommittedQueueSnapshot: Vector[(Long, T)]
- Definition Classes
- RecoveringFutureQueueImpl → RecoveringFutureQueue
- 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])