io.parallec.core.actor.message

Class RequestToBatchSenderAsstManager

java.lang.Object

io.parallec.core.actor.message.RequestToBatchSenderAsstManager

public class RequestToBatchSenderAsstManager
extends java.lang.Object

The Class RequestToBatchSenderAsstManager.

Field Summary

Fields

Modifier and Type	Field and Description
private long	asstManagerRetryIntervalMillis The asst manager retry interval millis.
private int	maxConcurrency The max concurrency.
private akka.actor.ActorRef	sender The sender.
private java.lang.String	taskId The task id.
private java.util.List<akka.actor.ActorRef>	workers The workers: list of actor ref.

Constructor Summary

Constructors

Constructor and Description
RequestToBatchSenderAsstManager() used for pojo test only.
RequestToBatchSenderAsstManager(java.lang.String directorJobId, long asstManagerRetryIntervalMillis, java.util.List<akka.actor.ActorRef> workers, akka.actor.ActorRef sender, int maxConcurrency) Instantiates a new request to batch sender asst manager.

Method Summary

Modifier and Type	Method and Description
long	getAsstManagerRetryIntervalMillis() Gets the asst manager retry interval millis.
int	getMaxConcurrency() Gets the max concurrency.
akka.actor.ActorRef	getSender() Gets the sender.
java.lang.String	getTaskId() Gets the task id.
java.util.List<akka.actor.ActorRef>	getWorkers() Gets the workers.

Methods inherited from class java.lang.Object

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

Field Detail

taskId

private final java.lang.String taskId

The task id.

asstManagerRetryIntervalMillis

private final long asstManagerRetryIntervalMillis

The asst manager retry interval millis.

maxConcurrency

private final int maxConcurrency

The max concurrency.

workers

private final java.util.List<akka.actor.ActorRef> workers

The workers: list of actor ref. cannot be empty because coming from

sender

private final akka.actor.ActorRef sender

The sender.

Constructor Detail

RequestToBatchSenderAsstManager

public RequestToBatchSenderAsstManager()

used for pojo test only.

RequestToBatchSenderAsstManager

public RequestToBatchSenderAsstManager(java.lang.String directorJobId,
                                       long asstManagerRetryIntervalMillis,
                                       java.util.List<akka.actor.ActorRef> workers,
                                       akka.actor.ActorRef sender,
                                       int maxConcurrency)

Instantiates a new request to batch sender asst manager.

Parameters:

directorJobId - the director job id

asstManagerRetryIntervalMillis - the asst manager retry interval millis

workers - the workers

sender - the sender

maxConcurrency - the max concurrency

Method Detail

getMaxConcurrency

public int getMaxConcurrency()

Gets the max concurrency.

Returns:

the max concurrency

getTaskId

public java.lang.String getTaskId()

Gets the task id.

Returns:

the task id

getWorkers

public java.util.List<akka.actor.ActorRef> getWorkers()

Gets the workers.

Returns:

the workers

getSender

public akka.actor.ActorRef getSender()

Gets the sender.

Returns:

the sender

getAsstManagerRetryIntervalMillis

public long getAsstManagerRetryIntervalMillis()

Gets the asst manager retry interval millis.

Returns:

the asst manager retry interval millis