Packages

package pubsub

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. final case class AcknowledgeRequest(ackIds: Seq[String]) extends Product with Serializable
  2. class PubSubConfig extends AnyRef

  3. final case class PubSubMessage(data: String, messageId: String, attributes: Option[Map[String, String]] = None, publishTime: Option[Instant] = None) extends Product with Serializable

    data

    the base64 encoded data

    messageId

    the message id

    attributes

    optional extra attributes for this message.

    publishTime

    the time the message was published. It must not be populated when publishing.

  4. final case class PublishRequest(messages: Seq[PubSubMessage]) extends Product with Serializable
  5. final case class ReceivedMessage(ackId: String, message: PubSubMessage) extends Product with Serializable

    A message as it is received

    A message as it is received

    ackId

    acknowledgement id. This id is used to tell pub/sub the message has been processed.

    message

    the pubsub message including its data.

Ungrouped