package pubsub
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- final case class AcknowledgeRequest(ackIds: Seq[String]) extends Product with Serializable
- class PubSubConfig extends AnyRef
-
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 given by server. It must not be populated when publishing.
- attributes
optional extra attributes for this message.
- publishTime
the time the message was published. It must not be populated when publishing.
- final case class PublishRequest(messages: Seq[PubSubMessage]) extends Product with Serializable
-
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.
Value Members
- object AcknowledgeRequest extends Serializable
- object PubSubConfig
- object PubSubMessage extends Serializable
- object PublishRequest extends Serializable