raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

fix incorrect config name (serialization-jackson) (#567)

Browse source 
* fix incorrect config name

* Update JacksonObjectMapperProvider.scala
This commit is contained in:
PJ Fanning 2023-08-14 09:22:37 +01:00 • committed by GitHub
parent 80e4e800c8
commit 02595bbfd4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonObjectMapperProvider.scala
View file

@ -230,7 +230,7 @@ object JacksonObjectMapperProvider extends ExtensionId[JacksonObjectMapperProvid
e, e,
s"Could not load configured Jackson module [$fqcn], " + s"Could not load configured Jackson module [$fqcn], " +
"please verify classpath dependencies or amend the configuration " + "please verify classpath dependencies or amend the configuration " +
"[pekko.serialization.jackson-modules]. Continuing without this module.")) "[pekko.serialization.jackson.jackson-modules]. Continuing without this module."))
None None
} }
} else } else
@ -303,7 +303,7 @@ object JacksonObjectMapperProvider extends ExtensionId[JacksonObjectMapperProvid
} }
/** /**
* Registry of shared `ObjectMapper` instances, each with it's unique `bindingName`. * Registry of shared `ObjectMapper` instances, each with its unique `bindingName`.
*/ */
final class JacksonObjectMapperProvider(system: ExtendedActorSystem) extends Extension { final class JacksonObjectMapperProvider(system: ExtendedActorSystem) extends Extension {
private val objectMappers = new ConcurrentHashMap[String, ObjectMapper] private val objectMappers = new ConcurrentHashMap[String, ObjectMapper]

2
serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
View file

@ -464,7 +464,7 @@ import pekko.util.OptionVal
private def isBoundToJacksonSerializer(clazz: Class[_]): Boolean = { private def isBoundToJacksonSerializer(clazz: Class[_]): Boolean = {
try { try {
// The reason for using isInstanceOf rather than `eq this` is to allow change of // The reason for using isInstanceOf rather than `eq this` is to allow change of
// serializizer within the Jackson family, but we don't trust other serializers // serializer within the Jackson family, but we don't trust other serializers
// because they might be bound to open-ended interfaces like java.io.Serializable. // because they might be bound to open-ended interfaces like java.io.Serializable.
val boundSerializer = serialization.serializerFor(clazz) val boundSerializer = serialization.serializerFor(clazz)
boundSerializer.isInstanceOf[JacksonSerializer] boundSerializer.isInstanceOf[JacksonSerializer]