Akka/Scala example source code file (MessageFormats.proto)

This example Akka source code file (MessageFormats.proto) is included in my "Source Code Warehouse" project. The intent of this project is to help you more easily find Akka and Scala source code examples by using tags.

All credit for the original source code belongs to akka.io; I'm just trying to make examples easier to find. (For my Scala work, see my Scala examples and tutorials.)

Akka tags/keywords

atleastoncedeliverysnapshot, deliveredmessage, delivermessage, persistentmessage, persistentmessagebatch, persistentpayload, speed, unconfirmeddelivery

The MessageFormats.proto Akka example source code

/**
 * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com>
 */

option java_package = "akka.persistence.serialization";
option optimize_for = SPEED;

message PersistentMessageBatch {
  repeated PersistentMessage batch = 1;
}

message PersistentMessage {
  optional PersistentPayload payload = 1;
  optional int64 sequenceNr = 2;
  optional string persistenceId = 3;
  optional bool deleted = 4;
  optional int32 redeliveries = 6;
  repeated string confirms = 7;
  optional bool confirmable = 8;
  optional DeliveredMessage confirmMessage = 9;
  optional string confirmTarget = 10;
  optional string sender = 11;
}

message PersistentPayload {
  required int32 serializerId = 1;
  required bytes payload = 2;
  optional bytes payloadManifest = 3;
}

message DeliveredMessage {
  optional string persistenceId = 1;
  optional string channelId = 2;
  optional int64 persistentSequenceNr = 3;
  optional int64 deliverySequenceNr = 4;
  optional string channel = 5;
}

message DeliverMessage {
  optional PersistentMessage persistent = 1;
  optional string destination = 2;
}

message AtLeastOnceDeliverySnapshot {
  message UnconfirmedDelivery {
    required int64 deliveryId = 1;
    required string destination = 2;
    required PersistentPayload payload = 3;
  }
  
  required int64 currentDeliveryId = 1;
  repeated UnconfirmedDelivery unconfirmedDeliveries = 2;
}