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
ConstructorsConstructorDescriptionXmlContentProcessor(io.micronaut.http.server.netty.NettyHttpRequest<?> nettyHttpRequest, io.micronaut.http.server.HttpServerConfiguration configuration) -
Method Summary
Modifier and TypeMethodDescriptionvoidcomplete(Collection<Object> out) protected voidonData(io.netty.buffer.ByteBufHolder message, Collection<Object> out) Methods inherited from class io.micronaut.http.server.netty.AbstractHttpContentProcessor
add, fireExceedsLengthMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface io.micronaut.http.server.netty.HttpContentProcessor
cancel, processSingle, resultTypeMethods 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- TheNettyHttpRequestconfiguration- TheHttpServerConfiguration
-
-
Method Details
-
onData
protected void onData(io.netty.buffer.ByteBufHolder message, Collection<Object> out) throws Throwable - Specified by:
onDatain classio.micronaut.http.server.netty.AbstractHttpContentProcessor- Throws:
Throwable
-
complete
- Throws:
Throwable
-