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

    Java API

  29. def withAttributes(attributes: Seq[MessageSystemAttributeName]): SqsSourceSettings
  30. 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

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

  32. def withMaxBufferSize(maxBufferSize: Int): SqsSourceSettings

    Internal buffer size used by the Source.

    Internal buffer size used by the Source.

    Default: 100 messages

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

    Java API

  35. def withMessageAttributes(attributes: Seq[MessageAttributeName]): SqsSourceSettings
  36. def withParallelRequests(value: Int): SqsSourceSettings
  37. 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

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

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

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

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from AnyRef

Inherited from Any

Ungrouped