final case class PubsubMessage(data: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, attributes: Map[String, String] = _root_.scala.collection.immutable.Map.empty, messageId: String = "", publishTime: Option[Timestamp] = _root_.scala.None, orderingKey: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[PubsubMessage] with Product with Serializable

A message that is published by publishers and consumed by subscribers. The message must contain either a non-empty data field or at least one attribute. Note that client libraries represent this object differently depending on the language. See the corresponding [client library documentation](https://cloud.google.com/pubsub/docs/reference/libraries) for more information. See [quotas and limits] (https://cloud.google.com/pubsub/quotas) for more information about message limits.

data

The message data field. If this field is empty, the message must contain at least one attribute.

attributes

Attributes for this message. If this field is empty, the message must contain non-empty data. This can be used to filter messages on the subscription.

messageId

ID of this message, assigned by the server when the message is published. Guaranteed to be unique within the topic. This value may be read by a subscriber that receives a PubsubMessage via a Pull call or a push delivery. It must not be populated by the publisher in a Publish call.

publishTime

The time at which the message was published, populated by the server when it receives the Publish call. It must not be populated by the publisher in a Publish call.

orderingKey

If non-empty, identifies related messages for which publish order should be respected. If a Subscription has enable_message_ordering set to true, messages published with the same non-empty ordering_key value will be delivered to subscribers in the order in which they are received by the Pub/Sub system. All PubsubMessages published in a given PublishRequest must specify the same ordering_key value. For more information, see [ordering messages](https://cloud.google.com/pubsub/docs/ordering).

Annotations
@SerialVersionUID()
Source
PubsubMessage.scala
Linear Supertypes
Updatable[PubsubMessage], GeneratedMessage, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PubsubMessage
  2. Updatable
  3. GeneratedMessage
  4. Serializable
  5. Product
  6. Equals
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new PubsubMessage(data: ByteString = _root_.com.google.protobuf.ByteString.EMPTY, attributes: Map[String, String] = _root_.scala.collection.immutable.Map.empty, messageId: String = "", publishTime: Option[Timestamp] = _root_.scala.None, orderingKey: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty)

    data

    The message data field. If this field is empty, the message must contain at least one attribute.

    attributes

    Attributes for this message. If this field is empty, the message must contain non-empty data. This can be used to filter messages on the subscription.

    messageId

    ID of this message, assigned by the server when the message is published. Guaranteed to be unique within the topic. This value may be read by a subscriber that receives a PubsubMessage via a Pull call or a push delivery. It must not be populated by the publisher in a Publish call.

    publishTime

    The time at which the message was published, populated by the server when it receives the Publish call. It must not be populated by the publisher in a Publish call.

    orderingKey

    If non-empty, identifies related messages for which publish order should be respected. If a Subscription has enable_message_ordering set to true, messages published with the same non-empty ordering_key value will be delivered to subscribers in the order in which they are received by the Pub/Sub system. All PubsubMessages published in a given PublishRequest must specify the same ordering_key value. For more information, see [ordering messages](https://cloud.google.com/pubsub/docs/ordering).

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. def addAllAttributes(__vs: Iterable[(String, String)]): PubsubMessage
  5. def addAttributes(__vs: (String, String)*): PubsubMessage
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. val attributes: Map[String, String]
  8. def clearAttributes: PubsubMessage
  9. def clearPublishTime: PubsubMessage
  10. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  11. def companion: PubsubMessage.type
    Definition Classes
    PubsubMessage → GeneratedMessage
  12. val data: ByteString
  13. def discardUnknownFields: PubsubMessage
  14. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  16. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. def getField(__field: FieldDescriptor): PValue
    Definition Classes
    PubsubMessage → GeneratedMessage
  18. def getFieldByNumber(__fieldNumber: Int): Any
    Definition Classes
    PubsubMessage → GeneratedMessage
  19. def getPublishTime: Timestamp
  20. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  21. val messageId: String
  22. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. val orderingKey: String
  26. def productElementNames: Iterator[String]
    Definition Classes
    Product
  27. val publishTime: Option[Timestamp]
  28. def serializedSize: Int
    Definition Classes
    PubsubMessage → GeneratedMessage
  29. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  30. final def toByteArray: Array[Byte]
    Definition Classes
    GeneratedMessage
  31. final def toByteString: ByteString
    Definition Classes
    GeneratedMessage
  32. final def toPMessage: PMessage
    Definition Classes
    GeneratedMessage
  33. def toProtoString: String
    Definition Classes
    PubsubMessage → GeneratedMessage
  34. val unknownFields: UnknownFieldSet
  35. def update(ms: (Lens[PubsubMessage, PubsubMessage]) => Mutation[PubsubMessage]*): PubsubMessage
    Definition Classes
    Updatable
  36. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  39. def withAttributes(__v: Map[String, String]): PubsubMessage
  40. def withData(__v: ByteString): PubsubMessage
  41. def withMessageId(__v: String): PubsubMessage
  42. def withOrderingKey(__v: String): PubsubMessage
  43. def withPublishTime(__v: Timestamp): PubsubMessage
  44. def withUnknownFields(__v: UnknownFieldSet): PubsubMessage
  45. final def writeDelimitedTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage
  46. def writeTo(_output__: CodedOutputStream): Unit
    Definition Classes
    PubsubMessage → GeneratedMessage
  47. final def writeTo(output: OutputStream): Unit
    Definition Classes
    GeneratedMessage

Inherited from Updatable[PubsubMessage]

Inherited from GeneratedMessage

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped