Package org.apache.hc.core5.jackson2.http

Class JsonNodeEntityFallbackConsumer

java.lang.Object

org.apache.hc.core5.jackson2.http.JsonNodeEntityFallbackConsumer

All Implemented Interfaces:

AsyncDataConsumer, AsyncEntityConsumer<com.fasterxml.jackson.databind.JsonNode>, ResourceHolder

public class JsonNodeEntityFallbackConsumer
extends Object
implements AsyncEntityConsumer<com.fasterxml.jackson.databind.JsonNode>

AsyncEntityConsumer implementation that de-serializes incoming HTTP message entity into an JsonNode instance if the message content type is ContentType.APPLICATION_JSON or as a single text JsonNode if the message content type is not supported. This entity consumer is primarily intended for handling of response messages that represent a client or a server error (such as a response with 4xx or 5xx status).

Since:

5.5

Constructor Summary

Constructors

Constructor	Description
JsonNodeEntityFallbackConsumer(com.fasterxml.jackson.core.JsonFactory jsonFactory)
JsonNodeEntityFallbackConsumer(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
void	consume(ByteBuffer data)
void	failed(Exception cause)
com.fasterxml.jackson.databind.JsonNode	getContent()
void	releaseResources()
void	streamEnd(List<? extends Header> trailers)
void	streamStart(EntityDetails entityDetails, FutureCallback<com.fasterxml.jackson.databind.JsonNode> resultCallback)
void	updateCapacity(CapacityChannel capacityChannel)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JsonNodeEntityFallbackConsumer

public JsonNodeEntityFallbackConsumer(com.fasterxml.jackson.core.JsonFactory jsonFactory)

JsonNodeEntityFallbackConsumer

public JsonNodeEntityFallbackConsumer(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

streamStart

public void streamStart(EntityDetails entityDetails,
 FutureCallback<com.fasterxml.jackson.databind.JsonNode> resultCallback)
                 throws HttpException,
IOException

Specified by:

streamStart in interface AsyncEntityConsumer<com.fasterxml.jackson.databind.JsonNode>

Throws:

HttpException

IOException

getContent

public com.fasterxml.jackson.databind.JsonNode getContent()

Specified by:

getContent in interface AsyncEntityConsumer<com.fasterxml.jackson.databind.JsonNode>

updateCapacity

public void updateCapacity(CapacityChannel capacityChannel)
                    throws IOException

Specified by:

updateCapacity in interface AsyncDataConsumer

Throws:

IOException

consume

public void consume(ByteBuffer data)
             throws IOException

Specified by:

consume in interface AsyncDataConsumer

Throws:

IOException

streamEnd

public void streamEnd(List<? extends Header> trailers)
               throws HttpException,
IOException

Specified by:

streamEnd in interface AsyncDataConsumer

Throws:

HttpException

IOException

failed

public void failed(Exception cause)

Specified by:

failed in interface AsyncEntityConsumer<com.fasterxml.jackson.databind.JsonNode>

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder