diff --git a/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceProcessorManager.java b/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceProcessorManager.java index c883fa4c16a..d1900381245 100644 --- a/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceProcessorManager.java +++ b/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceProcessorManager.java @@ -54,10 +54,12 @@ public final class ProduceProcessorManager extends RegisterManager { - nonSerialViewMap.put(processor.getName(), processor); - Map prodProcessorMap = getObjMap() - .computeIfAbsent(processor.getName(), key -> new HashMap<>()); - prodProcessorMap.putIfAbsent(processor.getSerializationView(), processor); + if (!MediaType.SERVER_SENT_EVENTS.equals(processor.getName())) { + nonSerialViewMap.put(processor.getName(), processor); + Map prodProcessorMap = getObjMap() + .computeIfAbsent(processor.getName(), key -> new HashMap<>()); + prodProcessorMap.putIfAbsent(processor.getSerializationView(), processor); + } }); jsonProcessorMap = ensureFindValue(MediaType.APPLICATION_JSON); plainProcessorMap = ensureFindValue(MediaType.TEXT_PLAIN);