From 3da2d6178723d300d809ad2fab1f091908e577aa Mon Sep 17 00:00:00 2001 From: jboner Date: Wed, 14 Oct 2009 22:18:41 +0200 Subject: [PATCH] added NOOP serializer + fixed wrong servlet name in web.xml --- akka-actors/src/main/scala/serialization/Serializer.scala | 6 ++++++ akka-persistence/src/main/scala/CassandraStorage.scala | 3 ++- akka-samples-lift/src/main/webapp/WEB-INF/web.xml | 2 +- 3 files changed, 9 insertions(+), 2 deletions(-) diff --git a/akka-actors/src/main/scala/serialization/Serializer.scala b/akka-actors/src/main/scala/serialization/Serializer.scala index 2d2917e0b5..441a8c0aa3 100644 --- a/akka-actors/src/main/scala/serialization/Serializer.scala +++ b/akka-actors/src/main/scala/serialization/Serializer.scala @@ -37,6 +37,12 @@ object Serializer { val EMPTY_CLASS_ARRAY = Array[Class[_]]() val EMPTY_ANY_REF_ARRAY = Array[AnyRef]() + object NOOP extends Serializer { + def deepClone(obj: AnyRef): AnyRef = obj + def out(obj: AnyRef): Array[Byte] = obj.asInstanceOf[Array[Byte]] + def in(bytes: Array[Byte], clazz: Option[Class[_]]): AnyRef = bytes + } + /** * @author Jonas Bonér */ diff --git a/akka-persistence/src/main/scala/CassandraStorage.scala b/akka-persistence/src/main/scala/CassandraStorage.scala index 02f5f5dbec..ccf5d25b3a 100644 --- a/akka-persistence/src/main/scala/CassandraStorage.scala +++ b/akka-persistence/src/main/scala/CassandraStorage.scala @@ -46,11 +46,12 @@ object CassandraStorage extends MapStorage */ private[this] val serializer: Serializer = { - config.getString("akka.storage.cassandra.storage-format", "java") match { + config.getString("akka.storage.cassandra.storage-format", "manual") match { case "scala-json" => Serializer.ScalaJSON case "java-json" => Serializer.JavaJSON case "protobuf" => Serializer.Protobuf case "java" => Serializer.Java + case "manual" => Serializer.NOOP 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 + "]") diff --git a/akka-samples-lift/src/main/webapp/WEB-INF/web.xml b/akka-samples-lift/src/main/webapp/WEB-INF/web.xml index d474da1ca1..23348604bb 100755 --- a/akka-samples-lift/src/main/webapp/WEB-INF/web.xml +++ b/akka-samples-lift/src/main/webapp/WEB-INF/web.xml @@ -13,7 +13,7 @@ AkkaServlet - se.scalablesolutions.akka.kernel.rest.AkkaServlet + se.scalablesolutions.akka.rest.AkkaServlet AkkaServlet