- final case class AcknowledgeRequest(ackIds: Seq[String]) extends Product with Serializable
- class PubSubConfig extends AnyRef
PubSubMessage(data: String, messageId: String, attributes: Option[Map[String, String]] = None, publishTime: Option[Instant] = None) extends Product with Serializable
the base64 encoded data
the message id
optional extra attributes for this message.
the time the message was published. It must not be populated when publishing.
- final case class PublishRequest(messages: Seq[PubSubMessage]) extends Product with Serializable
ReceivedMessage(ackId: String, message: PubSubMessage) extends Product with Serializable
A message as it is received
acknowledgement id. This id is used to tell pub/sub the message has been processed.
the pubsub message including its data.