io.parallec.core.actor

Class UdpWorker

java.lang.Object

akka.actor.UntypedActor

io.parallec.core.actor.UdpWorker

All Implemented Interfaces:

akka.actor.Actor

public class UdpWorker
extends akka.actor.UntypedActor

A worker for single UDP request class

Author:

Yuanteng (Jeff) Pei

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UdpWorker.MyIdleHandler how to pass the idle event back to the worker.
static class	UdpWorker.UdpChannelHandler The Netty response/channel handler.
static class	UdpWorker.UdpPipelineFactory define the list of handlers for this channel.

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 org.jboss.netty.channel.Channel	channel The channel.
private static org.slf4j.Logger	logger The logger.
private java.lang.StringBuilder	responseSb The response sb.
private akka.actor.ActorRef	sender The sender.
private boolean	sentReply The sent reply.
private java.lang.String	targetHost The target host.
private scala.concurrent.duration.FiniteDuration	timeoutDuration The timeout duration.
private akka.actor.Cancellable	timeoutMessageCancellable The timeout message cancellable.
private int	tryCount The try count.
private UdpMeta	udpMeta The udp meta.

Constructor Summary

Constructors

Constructor and Description
UdpWorker(int actorMaxOperationTimeoutSec, UdpMeta udpMeta, java.lang.String targetHost) Instantiates a new udp worker.

Method Summary

Modifier and Type	Method and Description
org.jboss.netty.bootstrap.ConnectionlessBootstrap	bootStrapUdpClient() Creates the udpClient with proper handler.
void	cancelCancellable() Cancel cancellable.
static org.slf4j.Logger	getLogger() Gets the logger.
void	onComplete(java.lang.String response, boolean error, java.lang.String errorMessage, java.lang.String stackTrace, java.lang.String statusCode, int statusCodeInt) On complete.
void	onReceive(java.lang.Object message)
private void	reply(java.lang.String response, boolean error, java.lang.String errorMessage, java.lang.String stackTrace, java.lang.String statusCode, int statusCodeInt) First close the connection.
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.

udpMeta

private final UdpMeta udpMeta

The udp meta.

targetHost

private java.lang.String targetHost

The target host.

logger

private static org.slf4j.Logger logger

The logger.

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.

channel

private org.jboss.netty.channel.Channel channel

The channel.

responseSb

private java.lang.StringBuilder responseSb

The response sb.

Constructor Detail

UdpWorker

public UdpWorker(int actorMaxOperationTimeoutSec,
                 UdpMeta udpMeta,
                 java.lang.String targetHost)

Instantiates a new udp worker.

Parameters:

actorMaxOperationTimeoutSec - the actor max operation timeout sec

udpMeta - the udp meta

targetHost - the target host

Method Detail

bootStrapUdpClient

public org.jboss.netty.bootstrap.ConnectionlessBootstrap bootStrapUdpClient()
                                                                     throws HttpRequestCreateException

Creates the udpClient with proper handler.

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)

First close the connection. Then 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

onComplete

public void onComplete(java.lang.String response,
                       boolean error,
                       java.lang.String errorMessage,
                       java.lang.String stackTrace,
                       java.lang.String statusCode,
                       int statusCodeInt)

On complete.

Parameters:

response - the response

error - the error

errorMessage - the error message

stackTrace - the stack trace

statusCode - the status code

statusCodeInt - the status code int

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