Package io.micronaut.xml.jackson.server
Class XmlContentProcessor
java.lang.Object
io.micronaut.http.server.netty.AbstractHttpContentProcessor
io.micronaut.xml.jackson.server.XmlContentProcessor
- All Implemented Interfaces:
io.micronaut.core.util.Toggleable
,io.micronaut.http.server.netty.HttpContentProcessor
public class XmlContentProcessor
extends io.micronaut.http.server.netty.AbstractHttpContentProcessor
This class will handle subscribing to a Xml stream and binding once the events are complete in a non-blocking
manner.
- Since:
- 1.0.0
- Author:
- Sergey Vishnyakov, James Kleeh
-
Field Summary
Fields inherited from class io.micronaut.http.server.netty.AbstractHttpContentProcessor
advertisedLength, configuration, nettyHttpRequest, receivedLength, requestMaxSize
-
Constructor Summary
ConstructorDescriptionXmlContentProcessor
(io.micronaut.http.server.netty.NettyHttpRequest<?> nettyHttpRequest, io.micronaut.http.server.HttpServerConfiguration configuration) -
Method Summary
Modifier and TypeMethodDescriptionvoid
complete
(Collection<Object> out) protected void
onData
(io.netty.buffer.ByteBufHolder message, Collection<Object> out) Methods inherited from class io.micronaut.http.server.netty.AbstractHttpContentProcessor
add, fireExceedsLength
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.micronaut.http.server.netty.HttpContentProcessor
cancel, processSingle, resultType
Methods inherited from interface io.micronaut.core.util.Toggleable
isEnabled
-
Constructor Details
-
XmlContentProcessor
public XmlContentProcessor(io.micronaut.http.server.netty.NettyHttpRequest<?> nettyHttpRequest, io.micronaut.http.server.HttpServerConfiguration configuration) - Parameters:
nettyHttpRequest
- TheNettyHttpRequest
configuration
- TheHttpServerConfiguration
-
-
Method Details
-
onData
protected void onData(io.netty.buffer.ByteBufHolder message, Collection<Object> out) throws Throwable - Specified by:
onData
in classio.micronaut.http.server.netty.AbstractHttpContentProcessor
- Throws:
Throwable
-
complete
- Throws:
Throwable
-