io.parallec.core.bean

Class TaskRequest

java.lang.Object

io.parallec.core.bean.TaskRequest

public class TaskRequest
extends java.lang.Object

This is the request send to the operation worker. It contains the actual request that has been replaced if there are variables defined.

Author:

Yuanteng (Jeff) Pei

Field Summary

Fields

Modifier and Type	Field and Description
private int	actorMaxOperationTimeoutSec The actor max operation timeout sec.
private ParallecResponseHandler	handler The handler.
private java.lang.String	host The host.
private java.lang.String	hostUniform The host uniform.
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 PingMeta	pingMeta The ping meta.
private boolean	pollable The pollable.
private int	port The port.
private RequestProtocol	protocol The protocol.
private java.lang.String	requestContent The request content.
private java.lang.String	resourcePath The resource path.
private java.util.Map<java.lang.String,java.lang.Object>	responseContext The response context.
private ResponseHeaderMeta	responseHeaderMeta The response header meta.
private SshMeta	sshMeta The ssh meta.
private TcpMeta	tcpMeta The tcp meta.
private UdpMeta	udpMeta The tcp meta.

Constructor Summary

Constructors

Constructor and Description

TaskRequest(int actorMaxOperationTimeoutSec, RequestProtocol protocol, java.lang.String host, java.lang.String hostUniform, int port, java.lang.String resourcePath, java.lang.String requestContent, HttpMethod httpMethod, boolean pollable, java.util.Map<java.lang.String,java.lang.String> httpHeaderMap, ParallecResponseHandler handler, java.util.Map<java.lang.String,java.lang.Object> responseContext, SshMeta sshMeta, TcpMeta tcpMeta, UdpMeta udpMeta, PingMeta pingMeta, ResponseHeaderMeta responseHeaderMeta) Instantiates a new task request.

Method Summary

Modifier and Type	Method and Description
int	getActorMaxOperationTimeoutSec() Gets the actor max operation timeout sec.
ParallecResponseHandler	getHandler() Gets the handler.
java.lang.String	getHost() Gets the host.
java.lang.String	getHostUniform() Gets the host uniform.
java.util.Map<java.lang.String,java.lang.String>	getHttpHeaderMap() Gets the http header map.
HttpMethod	getHttpMethod() Gets the http method.
PingMeta	getPingMeta() Gets the ping meta.
int	getPort() Gets the port.
java.lang.String	getPostData() Gets the post data.
RequestProtocol	getProtocol() Gets the protocol.
java.lang.String	getRequestContent() Gets the request content.
java.lang.String	getResourcePath() Gets the resource path.
java.util.Map<java.lang.String,java.lang.Object>	getResponseContext() Gets the response context.
ResponseHeaderMeta	getResponseHeaderMeta() Gets the response header meta.
SshMeta	getSshMeta() Gets the ssh meta.
TcpMeta	getTcpMeta() Gets the tcp meta.
UdpMeta	getUdpMeta() Gets the udp meta.
boolean	isPollable() Checks if is pollable.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static org.slf4j.Logger logger

The logger.

actorMaxOperationTimeoutSec

private final int actorMaxOperationTimeoutSec

The actor max operation timeout sec.

resourcePath

private final java.lang.String resourcePath

The resource path.

requestContent

private final java.lang.String requestContent

The request content.

httpMethod

private final HttpMethod httpMethod

The http method.

pollable

private final boolean pollable

The pollable.

httpHeaderMap

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

The http header map.

protocol

private final RequestProtocol protocol

The protocol.

host

private final java.lang.String host

The host.

hostUniform

private final java.lang.String hostUniform

The host uniform.

port

private final int port

The port.

sshMeta

private final SshMeta sshMeta

The ssh meta.

tcpMeta

private final TcpMeta tcpMeta

The tcp meta.

udpMeta

private final UdpMeta udpMeta

The tcp meta.

pingMeta

private final PingMeta pingMeta

The ping meta.

handler

private final ParallecResponseHandler handler

The handler.

responseContext

private final java.util.Map<java.lang.String,java.lang.Object> responseContext

The response context.

responseHeaderMeta

private final ResponseHeaderMeta responseHeaderMeta

The response header meta.

Constructor Detail

TaskRequest

public TaskRequest(int actorMaxOperationTimeoutSec,
                   RequestProtocol protocol,
                   java.lang.String host,
                   java.lang.String hostUniform,
                   int port,
                   java.lang.String resourcePath,
                   java.lang.String requestContent,
                   HttpMethod httpMethod,
                   boolean pollable,
                   java.util.Map<java.lang.String,java.lang.String> httpHeaderMap,
                   ParallecResponseHandler handler,
                   java.util.Map<java.lang.String,java.lang.Object> responseContext,
                   SshMeta sshMeta,
                   TcpMeta tcpMeta,
                   UdpMeta udpMeta,
                   PingMeta pingMeta,
                   ResponseHeaderMeta responseHeaderMeta)

Instantiates a new task request.

Parameters:

actorMaxOperationTimeoutSec - the actor max operation timeout sec

protocol - the protocol

host - the host

hostUniform - the host uniform

port - the port

resourcePath - the resource path

requestContent - the request content

httpMethod - the http method

pollable - the pollable

httpHeaderMap - the http header map

handler - the handler

responseContext - the response context

sshMeta - the ssh meta

tcpMeta - the tcp meta

udpMeta - the udp meta

pingMeta - the ping meta

responseHeaderMeta - the response header meta

Method Detail

getResourcePath

public java.lang.String getResourcePath()

Gets the resource path.

Returns:

the resource path

getHttpMethod

public HttpMethod getHttpMethod()

Gets the http method.

Returns:

the http method

getPostData

public java.lang.String getPostData()

Gets the post data.

Returns:

the post data

getRequestContent

public java.lang.String getRequestContent()

Gets the request content.

Returns:

the request content

isPollable

public boolean isPollable()

Checks if is pollable.

Returns:

true, if is pollable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getHttpHeaderMap

public java.util.Map<java.lang.String,java.lang.String> getHttpHeaderMap()

Gets the http header map.

Returns:

the http header map

getProtocol

public RequestProtocol getProtocol()

Gets the protocol.

Returns:

the protocol

getHost

public java.lang.String getHost()

Gets the host.

Returns:

the host

getHostUniform

public java.lang.String getHostUniform()

Gets the host uniform.

Returns:

the host uniform

getPort

public int getPort()

Gets the port.

Returns:

the port

getSshMeta

public SshMeta getSshMeta()

Gets the ssh meta.

Returns:

the ssh meta

getActorMaxOperationTimeoutSec

public int getActorMaxOperationTimeoutSec()

Gets the actor max operation timeout sec.

Returns:

the actor max operation timeout sec

getTcpMeta

public TcpMeta getTcpMeta()

Gets the tcp meta.

Returns:

the tcp meta

getPingMeta

public PingMeta getPingMeta()

Gets the ping meta.

Returns:

the ping meta

getHandler

public ParallecResponseHandler getHandler()

Gets the handler.

Returns:

the handler

getResponseContext

public java.util.Map<java.lang.String,java.lang.Object> getResponseContext()

Gets the response context.

Returns:

the response context

getUdpMeta

public UdpMeta getUdpMeta()

Gets the udp meta.

Returns:

the udp meta

getResponseHeaderMeta

public ResponseHeaderMeta getResponseHeaderMeta()

Gets the response header meta.

Returns:

the response header meta