org.apache.pekko.stream.connectors.ironmq.IronMqSettings
ConsumerSettings
Companion object ConsumerSettings
final class ConsumerSettings extends AnyRef
- Source
- IronMqSettings.scala
- Alphabetic
- By Inheritance
- ConsumerSettings
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- val bufferMaxSize: Int
- val bufferMinSize: Int
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- val fetchInterval: FiniteDuration
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val pollTimeout: FiniteDuration
- val reservationTimeout: FiniteDuration
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- ConsumerSettings → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()
- def withBufferMaxSize(value: Int): ConsumerSettings
The maximum number of buffered messages.
- def withBufferMinSize(value: Int): ConsumerSettings
The buffer size limit where a new batch of message will be consumed from the queue.
- def withFetchInterval(value: Duration): ConsumerSettings
Java API: The interval of time between each poll loop.
- def withFetchInterval(value: FiniteDuration): ConsumerSettings
Scala API: The interval of time between each poll loop.
- def withPollTimeout(value: Duration): ConsumerSettings
Java API: The amount of time the consumer will wait for the messages to be available on the queue.
Java API: The amount of time the consumer will wait for the messages to be available on the queue. The IronMQ time unit is the second so any other value is approximated to the second.
- def withPollTimeout(value: FiniteDuration): ConsumerSettings
Scala API: The amount of time the consumer will wait for the messages to be available on the queue.
Scala API: The amount of time the consumer will wait for the messages to be available on the queue. The IronMQ time unit is the second so any other value is approximated to the second.
- def withReservationTimeout(value: Duration): ConsumerSettings
Java API: The amount of time the consumer will reserve the message from.
Java API: The amount of time the consumer will reserve the message from. It should be higher that the time needed to process the message otherwise the same message will be processed multiple times. Again the IronMq time unit is the second.
- def withReservationTimeout(value: FiniteDuration): ConsumerSettings
Scala API: The amount of time the consumer will reserve the message from.
Scala API: The amount of time the consumer will reserve the message from. It should be higher that the time needed to process the message otherwise the same message will be processed multiple times. Again the IronMq time unit is the second.