Google Cloud Pub/Sub ordering key

[LukBed]

Short description

GCP Pub/Sub supports ordering by optional ordering key - unfortunately it's not supported by Alpakka so far.

Details

PubSub message in Google Cloud REST API

{
  "data": string,
  "attributes": {
    string: string,
    ...
  },
  "messageId": string,
  "publishTime": string,
  "orderingKey": string
}

Alpaka model

final class PubSubMessage private (val data: Option[String],
                                   val attributes: Option[immutable.Map[String, String]],
                                   val messageId: String,
                                   val publishTime: Instant) 

Ordering can be implemented by adding orderingKey field to PubSubMessage.