services.moleculer.httpclient

Class ResponseHandler

java.lang.Object

services.moleculer.httpclient.ResponseHandler

All Implemented Interfaces:

org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Direct Known Subclasses:

ResponseToBytes, ResponseToOutputStream, ResponseToPacketStream

public abstract class ResponseHandler
extends java.lang.Object
implements org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Base class for response parsers (JSON, byte-array, etc).

Nested Class Summary

Nested classes/interfaces inherited from interface org.asynchttpclient.AsyncHandler

org.asynchttpclient.AsyncHandler.State

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.handler.codec.http.HttpHeaders	httpHeaders
protected RequestParams	params
protected int	status

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ResponseHandler(RequestParams params)

Method Summary

Modifier and Type	Method and Description
protected void	addStatusAndHeaders(io.datatree.Tree rsp)
abstract org.asynchttpclient.AsyncHandler.State	onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart bodyPart)
abstract io.datatree.Tree	onCompleted()
org.asynchttpclient.AsyncHandler.State	onHeadersReceived(io.netty.handler.codec.http.HttpHeaders httpHeaders)
org.asynchttpclient.AsyncHandler.State	onStatusReceived(org.asynchttpclient.HttpResponseStatus responseStatus)
void	onThrowable(java.lang.Throwable t)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.asynchttpclient.AsyncHandler

onConnectionOffer, onConnectionPoolAttempt, onConnectionPooled, onHostnameResolutionAttempt, onHostnameResolutionFailure, onHostnameResolutionSuccess, onRequestSend, onRetry, onTcpConnectAttempt, onTcpConnectFailure, onTcpConnectSuccess, onTlsHandshakeAttempt, onTlsHandshakeFailure, onTlsHandshakeSuccess, onTrailingHeadersReceived

Field Detail

params

protected final RequestParams params

status

protected volatile int status

httpHeaders

protected volatile io.netty.handler.codec.http.HttpHeaders httpHeaders

Constructor Detail

ResponseHandler

protected ResponseHandler(RequestParams params)

Method Detail

onStatusReceived

public org.asynchttpclient.AsyncHandler.State onStatusReceived(org.asynchttpclient.HttpResponseStatus responseStatus)
                                                        throws java.lang.Exception

Specified by:

onStatusReceived in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Throws:

java.lang.Exception

onHeadersReceived

public org.asynchttpclient.AsyncHandler.State onHeadersReceived(io.netty.handler.codec.http.HttpHeaders httpHeaders)
                                                         throws java.lang.Exception

Specified by:

onHeadersReceived in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Throws:

java.lang.Exception

onThrowable

public void onThrowable(java.lang.Throwable t)

Specified by:

onThrowable in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

addStatusAndHeaders

protected void addStatusAndHeaders(io.datatree.Tree rsp)

onBodyPartReceived

public abstract org.asynchttpclient.AsyncHandler.State onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart bodyPart)
                                                                   throws java.lang.Exception

Specified by:

onBodyPartReceived in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Throws:

java.lang.Exception

onCompleted

public abstract io.datatree.Tree onCompleted()
                                      throws java.lang.Exception

Specified by:

onCompleted in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Throws:

java.lang.Exception