final class SqsSourceSettings extends AnyRef

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

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 attributeNames: Seq[MessageSystemAttributeName]
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. val closeOnEmptyReceive: Boolean
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. val maxBatchSize: Int
  15. val maxBufferSize: Int
  16. val messageAttributeNames: Seq[MessageAttributeName]
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. val parallelRequests: Int
  21. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    SqsSourceSettings → AnyRef → Any
  23. val visibilityTimeout: Option[FiniteDuration]
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  27. val waitTimeSeconds: Int
  28. def withAttribute(attribute: MessageSystemAttributeName): SqsSourceSettings
  29. def withAttributes(attributes: List[MessageSystemAttributeName]): SqsSourceSettings

    Java API

  30. def withAttributes(attributes: Seq[MessageSystemAttributeName]): SqsSourceSettings
  31. def withCloseOnEmptyReceive(value: Boolean): SqsSourceSettings

    If true, the source completes when no messages are available.

    If true, the source completes when no messages are available.

    Default: false

  32. def withMaxBatchSize(maxBatchSize: Int): SqsSourceSettings

    The maximum number of messages to return (see MaxNumberOfMessages in AWS docs).

    The maximum number of messages to return (see MaxNumberOfMessages in AWS docs). Default: 10

  33. def withMaxBufferSize(maxBufferSize: Int): SqsSourceSettings

    Internal buffer size used by the Source.

    Internal buffer size used by the Source.

    Default: 100 messages

  34. def withMessageAttribute(attributes: MessageAttributeName): SqsSourceSettings
  35. def withMessageAttributes(attributes: List[MessageAttributeName]): SqsSourceSettings

    Java API

  36. def withMessageAttributes(attributes: Seq[MessageAttributeName]): SqsSourceSettings
  37. def withParallelRequests(value: Int): SqsSourceSettings
  38. def withVisibilityTimeout(timeout: FiniteDuration): SqsSourceSettings

    the period of time (in seconds) during which Amazon SQS prevents other consumers from receiving and processing an already received message (see Amazon SQS doc)

    the period of time (in seconds) during which Amazon SQS prevents other consumers from receiving and processing an already received message (see Amazon SQS doc)

    Default: None - taken from the SQS queue configuration

  39. def withWaitTime(duration: Duration): SqsSourceSettings

    Java API

    Java API

    The duration in seconds for which the call waits for a message to arrive in the queue before returning. (see WaitTimeSeconds in AWS docs).

    Default: 20 seconds

  40. def withWaitTime(duration: FiniteDuration): SqsSourceSettings

    The duration for which the call waits for a message to arrive in the queue before returning.

    The duration for which the call waits for a message to arrive in the queue before returning. (see WaitTimeSeconds in AWS docs).

    Default: 20 seconds

  41. def withWaitTimeSeconds(seconds: Int): SqsSourceSettings

    The duration in seconds for which the call waits for a message to arrive in the queue before returning.

    The duration in seconds for which the call waits for a message to arrive in the queue before returning. (see WaitTimeSeconds in AWS docs). Default: 20 seconds

Inherited from AnyRef

Inherited from Any

Ungrouped