|
29 | 29 | import org.apache.axis2.builder.Builder; |
30 | 30 | import org.apache.axis2.context.MessageContext; |
31 | 31 | import org.apache.axis2.json.factory.JsonConstant; |
| 32 | +import org.apache.axis2.json.moshi.MoshiXMLStreamReader; |
32 | 33 | import org.apache.commons.logging.Log; |
33 | 34 | import org.apache.commons.logging.LogFactory; |
34 | 35 |
|
@@ -313,14 +314,12 @@ private OMElement processWithEnhancedMoshi(InputStream inputStream, MessageConte |
313 | 314 | jsonReader = JsonReader.of(source); |
314 | 315 | jsonReader.setLenient(true); |
315 | 316 |
|
316 | | - // Create enhanced MoshiXMLStreamReader with field-specific optimizations |
317 | | - EnhancedMoshiXMLStreamReader enhancedStreamReader = new EnhancedMoshiXMLStreamReader( |
318 | | - jsonReader, strategy, requestId, metrics |
319 | | - ); |
| 317 | + // Create MoshiXMLStreamReader with enhanced processing context |
| 318 | + MoshiXMLStreamReader streamReader = new MoshiXMLStreamReader(jsonReader); |
320 | 319 |
|
321 | 320 | // Set enhanced properties in message context |
322 | | - messageContext.setProperty(JsonConstant.MOSHI_XML_STREAM_READER, enhancedStreamReader); |
323 | | - messageContext.setProperty("ENHANCED_MOSHI_H2_READER", enhancedStreamReader); |
| 321 | + messageContext.setProperty(JsonConstant.MOSHI_XML_STREAM_READER, streamReader); |
| 322 | + messageContext.setProperty("ENHANCED_MOSHI_H2_READER", streamReader); |
324 | 323 | messageContext.setProperty("PROCESSING_STRATEGY", strategy); |
325 | 324 |
|
326 | 325 | if (log.isDebugEnabled()) { |
|
0 commit comments