io.parallec.core.actor

Class SshWorker

java.lang.Object

akka.actor.UntypedActor

io.parallec.core.actor.SshWorker

All Implemented Interfaces:

akka.actor.Actor

public class SshWorker
extends akka.actor.UntypedActor

Using callable to start a new thread to run the SSH execution task (which make take minutes). Check if future is read every 0.5seconds Make sure the message are handled async. Note that a blocking message will block all subsequent messages.

Author:

Yuanteng (Jeff) Pei

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	SshWorker.SshTask thread to return the future.

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 static org.slf4j.Logger	logger The logger.
private java.util.concurrent.Future<ResponseOnSingeRequest>	responseFuture The response future.
private akka.actor.ActorRef	sender The sender.
private boolean	sentReply The sent reply.
private SshMeta	sshMeta The ssh meta.
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.

Constructor Summary

Constructors

Constructor and Description
SshWorker(int actorMaxOperationTimeoutSec, SshMeta sshMeta, java.lang.String targetHost) Instantiates a new ssh worker.

Method Summary

Modifier and Type	Method and Description
void	cancelCancellable() Cancel cancellable.
static org.slf4j.Logger	getLogger() Gets the logger.
java.util.concurrent.Future<ResponseOnSingeRequest>	getResponseFuture() Gets the response future.
boolean	isSentReply() Checks if is sent reply.
void	onComplete(ResponseOnSingeRequest sshResponse) On complete.
void	onReceive(java.lang.Object message)
private void	reply(java.lang.String response, boolean failObtainResponse, java.lang.String errorMessage, java.lang.String stackTrace, java.lang.String statusCode, int statusCodeInt) Reply.
static void	setLogger(org.slf4j.Logger logger) Sets the logger.
void	setResponseFuture(java.util.concurrent.Future<ResponseOnSingeRequest> responseFuture) Sets the response future.
void	setSentReply(boolean sentReply) Sets the sent reply.

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

logger

private static org.slf4j.Logger logger

The logger.

actorMaxOperationTimeoutSec

private int actorMaxOperationTimeoutSec

The actor max operation timeout sec.

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.

sshMeta

private SshMeta sshMeta

The ssh meta.

targetHost

private java.lang.String targetHost

The target host.

responseFuture

private java.util.concurrent.Future<ResponseOnSingeRequest> responseFuture

The response future.

Constructor Detail

SshWorker

public SshWorker(int actorMaxOperationTimeoutSec,
                 SshMeta sshMeta,
                 java.lang.String targetHost)

Instantiates a new ssh worker.

Parameters:

actorMaxOperationTimeoutSec - the actor max operation timeout sec

sshMeta - the ssh meta

targetHost - the target host

Method Detail

onReceive

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

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception

onComplete

public void onComplete(ResponseOnSingeRequest sshResponse)

On complete.

Parameters:

sshResponse - the ssh response

cancelCancellable

public void cancelCancellable()

Cancel cancellable.

reply

private void reply(java.lang.String response,
                   boolean failObtainResponse,
                   java.lang.String errorMessage,
                   java.lang.String stackTrace,
                   java.lang.String statusCode,
                   int statusCodeInt)

Reply.

Parameters:

response - the response

failObtainResponse - the fail obtain response

errorMessage - the error message

stackTrace - the stack trace

statusCode - the status code

statusCodeInt - the status code int

isSentReply

public boolean isSentReply()

Checks if is sent reply.

Returns:

true, if is sent reply

setSentReply

public void setSentReply(boolean sentReply)

Sets the sent reply.

Parameters:

sentReply - the new sent reply

getResponseFuture

public java.util.concurrent.Future<ResponseOnSingeRequest> getResponseFuture()

Gets the response future.

Returns:

the response future

setResponseFuture

public void setResponseFuture(java.util.concurrent.Future<ResponseOnSingeRequest> responseFuture)

Sets the response future.

Parameters:

responseFuture - the new response future

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