Packages

c

monix.connect.sqs.producer

StandardMessage

final case class StandardMessage(body: String, messageAttributes: Map[String, MessageAttribute] = Map.empty, awsTraceHeader: Option[MessageAttribute] = None, delayDuration: Option[FiniteDuration] = None) extends Message with Product with Serializable

The message type representation to be sent to a Standard Sqs queue.

The main differences between FifoMessage is that it does not need deduplication nor groupId, on the other hand it can contain delayDuration, which is not supported in fifo queues.

body

message content

messageAttributes

structured metadata (such as timestamps, signatures, and identifiers) that goes alongside the message. and that the consumer can use it to handle a in a particular way without having to process the message body first. Each message can have up to 10 attributes. See more in the SQS AWS Message Attributes gide..

awsTraceHeader

a message system attribute to carry the X-Ray trace header with messages in the queue. Its type must be String and its value must be a correctly formatted AWS X-Ray trace header string. The size of a message system attribute doesn't count towards the total size of a message. See more in the Xray sqs service docs..

delayDuration

The length of time, in seconds, for which a specific message is delayed. Valid values: 0 to 900. Maximum: 15 minutes. Messages with a positive DelaySeconds value become available for processing after the delay period is finished. If you don't specify a value, the default value for the queue is applied. FifoMessages do not support this field because it is not supported by FifoQueues. You can set this parameter only on a queue level.

Source
StandardMessage.scala
See also

Standard queues..

Linear Supertypes
Serializable, Product, Equals, Message, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StandardMessage
  2. Serializable
  3. Product
  4. Equals
  5. Message
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new StandardMessage(body: String, messageAttributes: Map[String, MessageAttribute] = Map.empty, awsTraceHeader: Option[MessageAttribute] = None, delayDuration: Option[FiniteDuration] = None)

    body

    message content

    messageAttributes

    structured metadata (such as timestamps, signatures, and identifiers) that goes alongside the message. and that the consumer can use it to handle a in a particular way without having to process the message body first. Each message can have up to 10 attributes. See more in the SQS AWS Message Attributes gide..

    awsTraceHeader

    a message system attribute to carry the X-Ray trace header with messages in the queue. Its type must be String and its value must be a correctly formatted AWS X-Ray trace header string. The size of a message system attribute doesn't count towards the total size of a message. See more in the Xray sqs service docs..

    delayDuration

    The length of time, in seconds, for which a specific message is delayed. Valid values: 0 to 900. Maximum: 15 minutes. Messages with a positive DelaySeconds value become available for processing after the delay period is finished. If you don't specify a value, the default value for the queue is applied. FifoMessages do not support this field because it is not supported by FifoQueues. You can set this parameter only on a queue level.

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 awsTraceHeader: Option[MessageAttribute]
  6. val body: String
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. val delayDuration: Option[FiniteDuration]
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. val messageAttributes: Map[String, MessageAttribute]
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. def productElementNames: Iterator[String]
    Definition Classes
    Product
  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from Message

Inherited from AnyRef

Inherited from Any

Ungrouped