Packages

final case class FifoMessage(body: String, groupId: String, deduplicationId: Option[String] = Option.empty, messageAttributes: Map[String, MessageAttribute] = Map.empty, awsTraceHeader: Option[MessageAttribute] = Option.empty) extends Message with Product with Serializable

The message representation to be sent to a FIFO queue.

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

Source
FifoMessage.scala
See also

Fifo queues..

Linear Supertypes
Serializable, Product, Equals, Message, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FifoMessage
  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 FifoMessage(body: String, groupId: String, deduplicationId: Option[String] = Option.empty, messageAttributes: Map[String, MessageAttribute] = Map.empty, awsTraceHeader: Option[MessageAttribute] = Option.empty)

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

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 deduplicationId: Option[String]
  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. val groupId: String
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. val messageAttributes: Map[String, MessageAttribute]
  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. def productElementNames: Iterator[String]
    Definition Classes
    Product
  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. 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