diff --git a/akka.iws b/akka.iws index 018dd9e128..ffffdcc102 100644 --- a/akka.iws +++ b/akka.iws @@ -6,9 +6,7 @@ - - - + @@ -132,19 +130,37 @@ - - + + - + - - + + - + + + + + + + + + + + + + + + + + + + @@ -204,24 +220,6 @@ - - - - - - - - - - - - - - - - - - @@ -235,7 +233,6 @@ @@ -578,6 +576,36 @@ - - - - - - - - - - - - - - @@ -2215,13 +2229,6 @@ - - - - - - - @@ -2285,9 +2292,30 @@ + + + + + + + + + + + + + + + + + + + + + - + diff --git a/kernel/src/main/scala/state/CassandraStorage.scala b/kernel/src/main/scala/state/CassandraStorage.scala index b065f87e03..3d1945c92e 100644 --- a/kernel/src/main/scala/state/CassandraStorage.scala +++ b/kernel/src/main/scala/state/CassandraStorage.scala @@ -43,9 +43,10 @@ object CassandraStorage extends Logging { kernel.Kernel.config.getString("akka.storage.cassandra.storage-format", "java") match { case "scala-json" => Serializer.ScalaJSON case "java-json" => Serializer.JavaJSON - //case "sbinary" => Serializer.SBinary + case "protobuf" => Serializer.Protobuf case "java" => Serializer.Java - case "avro" => throw new UnsupportedOperationException("Avro serialization protocol is not yet supported") + case "sbinary" => throw new UnsupportedOperationException("SBinary serialization protocol is not yet supported for storage") + case "avro" => throw new UnsupportedOperationException("Avro serialization protocol is not yet supported for storage") case unknown => throw new UnsupportedOperationException("Unknown storage serialization protocol [" + unknown + "]") } }