io.parallec.core.actor

Class HttpWorker

java.lang.Object

akka.actor.UntypedActor

io.parallec.core.actor.HttpWorker

All Implemented Interfaces:

akka.actor.Actor

public class HttpWorker
extends akka.actor.UntypedActor

This is an akka actor with async http client.

Author:

Yuanteng (Jeff) Pei

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	HttpWorker.HttpAsyncHandler Async HTTP Client handler wrapper.

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
private int	actorMaxOperationTimeoutSec The actor max operation timeout sec.
private java.lang.Throwable	cause The cause.
private com.ning.http.client.AsyncHttpClient	client The client.
private java.util.Map<java.lang.String,java.lang.String>	httpHeaderMap The http header map.
private HttpMethod	httpMethod The http method.
private static org.slf4j.Logger	logger The logger.
private java.lang.String	postData The post data.
private java.lang.String	requestUrl The request url.
(package private) com.ning.http.client.ListenableFuture<ResponseOnSingeRequest>	responseFuture The response future.
private ResponseHeaderMeta	responseHeaderMeta The response header meta: which keys are needed to get from response header.
private akka.actor.ActorRef	sender The sender.
private boolean	sentReply The sent reply.
private scala.concurrent.duration.FiniteDuration	timeoutDuration The timeout duration.
private akka.actor.Cancellable	timeoutMessageCancellable The timeout message cancellable.
private int	tryCount The try count.

Constructor Summary

Constructors

Constructor and Description
HttpWorker(int actorMaxOperationTimeoutSec, com.ning.http.client.AsyncHttpClient client, java.lang.String requestUrl, HttpMethod httpMethod, java.lang.String postData, java.util.Map<java.lang.String,java.lang.String> httpHeaderMap, ResponseHeaderMeta responseHeaderMeta) Instantiates a new http worker.

Method Summary

Modifier and Type	Method and Description
void	cancelCancellable() Cancel cancellable.
com.ning.http.client.AsyncHttpClient.BoundRequestBuilder	createRequest() Creates the request.
static org.slf4j.Logger	getLogger() Gets the logger.
ResponseOnSingeRequest	onComplete(com.ning.http.client.Response response) On complete.
void	onReceive(java.lang.Object message)
void	onThrowable(java.lang.Throwable cause) On throwable.
private void	reply(java.lang.String response, boolean error, java.lang.String errorMessage, java.lang.String stackTrace, java.lang.String statusCode, int statusCodeInt, java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders) Reply.
static void	setLogger(org.slf4j.Logger logger) Sets the logger.

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Field Detail

actorMaxOperationTimeoutSec

private int actorMaxOperationTimeoutSec

The actor max operation timeout sec.

client

private final com.ning.http.client.AsyncHttpClient client

The client.

requestUrl

private final java.lang.String requestUrl

The request url.

httpMethod

private final HttpMethod httpMethod

The http method.

postData

private final java.lang.String postData

The post data.

logger

private static org.slf4j.Logger logger

The logger.

httpHeaderMap

private final java.util.Map<java.lang.String,java.lang.String> httpHeaderMap

The http header map.

responseHeaderMeta

private final ResponseHeaderMeta responseHeaderMeta

The response header meta: which keys are needed to get from response header.

sender

private akka.actor.ActorRef sender

The sender.

cause

private java.lang.Throwable cause

The cause.

tryCount

private int tryCount

The try count.

timeoutMessageCancellable

private akka.actor.Cancellable timeoutMessageCancellable

The timeout message cancellable.

timeoutDuration

private scala.concurrent.duration.FiniteDuration timeoutDuration

The timeout duration.

sentReply

private boolean sentReply

The sent reply.

responseFuture

com.ning.http.client.ListenableFuture<ResponseOnSingeRequest> responseFuture

The response future.

Constructor Detail

HttpWorker

public HttpWorker(int actorMaxOperationTimeoutSec,
                  com.ning.http.client.AsyncHttpClient client,
                  java.lang.String requestUrl,
                  HttpMethod httpMethod,
                  java.lang.String postData,
                  java.util.Map<java.lang.String,java.lang.String> httpHeaderMap,
                  ResponseHeaderMeta responseHeaderMeta)

Instantiates a new http worker.

Parameters:

actorMaxOperationTimeoutSec - the actor max operation timeout sec

client - the client

requestUrl - the request url

httpMethod - the http method

postData - the post data

httpHeaderMap - the http header map

responseHeaderMeta - the response header meta

Method Detail

createRequest

public com.ning.http.client.AsyncHttpClient.BoundRequestBuilder createRequest()
                                                                       throws HttpRequestCreateException

Creates the request.

Returns:

the bound request builder

Throws:

HttpRequestCreateException - the http request create exception

onReceive

public void onReceive(java.lang.Object message)
               throws java.lang.Exception

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception

cancelCancellable

public void cancelCancellable()

Cancel cancellable.

reply

private void reply(java.lang.String response,
                   boolean error,
                   java.lang.String errorMessage,
                   java.lang.String stackTrace,
                   java.lang.String statusCode,
                   int statusCodeInt,
                   java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders)

Reply.

Parameters:

response - the response

error - the error

errorMessage - the error message

stackTrace - the stack trace

statusCode - the status code

statusCodeInt - the status code int

responseHeaders - the response headers

onComplete

public ResponseOnSingeRequest onComplete(com.ning.http.client.Response response)

On complete. Save response headers when needed.

Parameters:

response - the response

Returns:

the response on single request

onThrowable

public void onThrowable(java.lang.Throwable cause)

On throwable.

Parameters:

cause - the cause

getLogger

public static org.slf4j.Logger getLogger()

Gets the logger.

Returns:

the logger

setLogger

public static void setLogger(org.slf4j.Logger logger)

Sets the logger.

Parameters:

logger - the new logger