Skip to content

Commit babf3d4

Browse files
committed
feat: unknown fields ignored when consuming a JSON
1 parent f6ba91b commit babf3d4

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

extras-protobuf/src/main/scala/com/avast/clients/rabbitmq/extras/format/ProtobufAsJsonDeliveryConverter.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ object ProtobufAsJsonDeliveryConverter {
1717
def derive[A <: GeneratedMessageV3: ProtobufAsJsonDeliveryConverter](): ProtobufAsJsonDeliveryConverter[A] =
1818
implicitly[ProtobufAsJsonDeliveryConverter[A]]
1919

20-
private val jsonParser = JsonFormat.parser()
20+
private val jsonParser = JsonFormat.parser().ignoringUnknownFields()
2121

2222
implicit def createJsonDeliveryConverter[A <: GeneratedMessageV3: ClassTag]: ProtobufAsJsonDeliveryConverter[A] =
2323
new ProtobufAsJsonDeliveryConverter[A] {

extras-scalapb/src/main/scala/com/avast/clients/rabbitmq/extras/format/ScalaPBAsJsonDeliveryConverter.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ object ScalaPBAsJsonDeliveryConverter {
1818
def derive[A <: GeneratedMessage: GeneratedMessageCompanion: ScalaPBAsJsonDeliveryConverter](): ScalaPBAsJsonDeliveryConverter[A] =
1919
implicitly[ScalaPBAsJsonDeliveryConverter[A]]
2020

21-
private val jsonParser = new Parser()
21+
private val jsonParser = new Parser().ignoringUnknownFields
2222

2323
implicit def createJsonDeliveryConverter[A <: GeneratedMessage: GeneratedMessageCompanion: ClassTag]: ScalaPBAsJsonDeliveryConverter[A] =
2424
new ScalaPBAsJsonDeliveryConverter[A] {

0 commit comments

Comments
 (0)