Packages

final class ConsumerSettings extends AnyRef

Source
IronMqSettings.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConsumerSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. val bufferMaxSize: Int
  6. val bufferMinSize: Int
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. val fetchInterval: FiniteDuration
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. val pollTimeout: FiniteDuration
  19. val reservationTimeout: FiniteDuration
  20. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    ConsumerSettings → AnyRef → Any
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  25. def withBufferMaxSize(value: Int): ConsumerSettings

    The maximum number of buffered messages.

  26. def withBufferMinSize(value: Int): ConsumerSettings

    The buffer size limit where a new batch of message will be consumed from the queue.

  27. def withFetchInterval(value: Duration): ConsumerSettings

    Java API: The interval of time between each poll loop.

  28. def withFetchInterval(value: FiniteDuration): ConsumerSettings

    Scala API: The interval of time between each poll loop.

  29. 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.

  30. 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.

  31. 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.

  32. 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.

Inherited from AnyRef

Inherited from Any

Ungrouped