services.moleculer.httpclient

Class ResponseToPacketStream

java.lang.Object

services.moleculer.httpclient.ResponseHandler

services.moleculer.httpclient.ResponseToPacketStream

All Implemented Interfaces:

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

public class ResponseToPacketStream
extends ResponseHandler

Redirects response into the specific Moleculer PacketStream (eg. to another Moleculer node / service).

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 services.moleculer.stream.PacketStream	target

Fields inherited from class services.moleculer.httpclient.ResponseHandler

httpHeaders, params, status

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ResponseToPacketStream(RequestParams params, services.moleculer.stream.PacketStream target)

Method Summary

Modifier and Type	Method and Description
protected void	closeStream()
org.asynchttpclient.AsyncHandler.State	onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart bodyPart)
io.datatree.Tree	onCompleted()
void	onThrowable(java.lang.Throwable t)

Methods inherited from class services.moleculer.httpclient.ResponseHandler

addStatusAndHeaders, onHeadersReceived, onStatusReceived

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

target

protected final services.moleculer.stream.PacketStream target

Constructor Detail

ResponseToPacketStream

protected ResponseToPacketStream(RequestParams params,
                                 services.moleculer.stream.PacketStream target)

Method Detail

onThrowable

public void onThrowable(java.lang.Throwable t)

Specified by:

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

Overrides:

onThrowable in class ResponseHandler

onBodyPartReceived

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

Specified by:

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

Specified by:

onBodyPartReceived in class ResponseHandler

Throws:

java.lang.Exception

onCompleted

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

Specified by:

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

Specified by:

onCompleted in class ResponseHandler

Throws:

java.lang.Exception

closeStream

protected void closeStream()