com.alibaba.schedulerx.worker

类 SchedulerxWorker

java.lang.Object

com.alibaba.schedulerx.worker.SchedulerxWorker

所有已实现的接口:

EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ApplicationContextEvent>

public class SchedulerxWorker
extends Object
implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationListener<org.springframework.context.event.ApplicationContextEvent>

作者:

xiaomeng.hxm

字段概要

字段

限定符和类型	字段和说明
static akka.actor.ActorSystem	actorSystem
static akka.actor.ActorRef	AtLeastDeliveryRoutingActor
static ClassLoader	CUSTOMER_CLASS_LOADER
static Map<String,Long>	groupIdMap 已过时。
static boolean	INITED
static String	WORKER_ADDR

构造器概要

构造器

构造器和说明
SchedulerxWorker()

方法概要

限定符和类型	方法和说明
void	afterPropertiesSet()
void	appendWorkerInit()
org.apache.commons.configuration.Configuration	getConfig()
void	init()
static void	main(String[] args) !!!
void	onApplicationEvent(org.springframework.context.event.ApplicationContextEvent event)
static void	restartActorSystem()
void	setAkkaRemotingAutoRecover(boolean autoRecover)
void	setAliyunAccessKey(String aliyunAccessKey)
void	setAliyunSecretKey(String aliyunSecretKey)
void	setAppKey(String appKey)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setBlockAppStart(boolean block)
void	setCgroupPathPrefix(String cgroupPathPrefix) set cgroup path if the path is not '/sys/fs/cgroup/cpu/'
void	setClassLoader(ClassLoader userClassLoader)
void	setDisableSites(String sites)
void	setDisableUnits(String units)
void	setDomainName(String domainName)
void	setEnableBatchWork(boolean enableBatchWork)
void	setEnableCgroupMetrics(boolean enable) enable cgroup metrics collection in docker
void	setEnableHeartbeatLog(boolean enable)
void	setEnableSecondDelayCycleIntervalMs(boolean enable)
void	setEnableSites(String sites)
void	setEnableUnits(String units)
void	setEndpoint(String endpoint)
void	setEndpointPort(int endpointPort)
void	setGroupId(String groupId)
void	setHost(String host)
void	setLabel(String label)
void	setMapMasterStatusCheckInterval(int interval)
void	setMaxTaskBodySize(int maxSize)
void	setNamespace(String namespace)
void	setNamespaceSource(String namespaceSource)
void	setPort(int port)
void	setShareContainerPool(boolean shareConatinerPool)
void	setSharePoolSize(int sharePoolSize)
void	setSlsCollectorEnable(boolean enable) set sls collector switch, false value will not use sls log collector which may cause OOM default is true
void	setSTSAccessKey(String stsAccessKey)
void	setSTSSecretKey(String stsSecretKey)
void	setSTSSecretToken(String stsSecretToken)
static String	startActorSystem()

从类继承的方法 java.lang.Object

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

字段详细资料

actorSystem

public static akka.actor.ActorSystem actorSystem

AtLeastDeliveryRoutingActor

public static akka.actor.ActorRef AtLeastDeliveryRoutingActor

INITED

public static boolean INITED

CUSTOMER_CLASS_LOADER

public static ClassLoader CUSTOMER_CLASS_LOADER

WORKER_ADDR

public static String WORKER_ADDR

groupIdMap

@Deprecated
public static Map<String,Long> groupIdMap

已过时。

构造器详细资料

SchedulerxWorker

public SchedulerxWorker()

方法详细资料

init

public void init()
          throws Exception

抛出:

Exception

appendWorkerInit

public void appendWorkerInit()
                      throws Exception

抛出:

Exception

getConfig

public org.apache.commons.configuration.Configuration getConfig()

main

public static void main(String[] args)
                 throws Exception

!!! This method used by Schedulerx2Agent, treat it as production code, don't add test code to it!!!

抛出:

Exception

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

指定者:

setApplicationContext 在接口中 org.springframework.context.ApplicationContextAware

抛出:

org.springframework.beans.BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

指定者:

afterPropertiesSet 在接口中 org.springframework.beans.factory.InitializingBean

抛出:

Exception

setDomainName

public void setDomainName(String domainName)

setGroupId

public void setGroupId(String groupId)

setAppKey

public void setAppKey(String appKey)

setEnableBatchWork

public void setEnableBatchWork(boolean enableBatchWork)

restartActorSystem

public static void restartActorSystem()
                               throws Exception

抛出:

Exception

startActorSystem

public static String startActorSystem()
                               throws Exception

抛出:

Exception

setEnableUnits

public void setEnableUnits(String units)

setEnableSites

public void setEnableSites(String sites)

setDisableUnits

public void setDisableUnits(String units)

setDisableSites

public void setDisableSites(String sites)

setAliyunAccessKey

public void setAliyunAccessKey(String aliyunAccessKey)

setAliyunSecretKey

public void setAliyunSecretKey(String aliyunSecretKey)

setSTSAccessKey

public void setSTSAccessKey(String stsAccessKey)

setSTSSecretKey

public void setSTSSecretKey(String stsSecretKey)

setSTSSecretToken

public void setSTSSecretToken(String stsSecretToken)

setHost

public void setHost(String host)

setPort

public void setPort(int port)

setClassLoader

public void setClassLoader(ClassLoader userClassLoader)

setNamespace

public void setNamespace(String namespace)

setNamespaceSource

public void setNamespaceSource(String namespaceSource)

setEndpoint

public void setEndpoint(String endpoint)

setEndpointPort

public void setEndpointPort(int endpointPort)

setMaxTaskBodySize

public void setMaxTaskBodySize(int maxSize)

参数:

maxSize, - byte

setBlockAppStart

public void setBlockAppStart(boolean block)

setShareContainerPool

public void setShareContainerPool(boolean shareConatinerPool)

setSharePoolSize

public void setSharePoolSize(int sharePoolSize)

setSlsCollectorEnable

public void setSlsCollectorEnable(boolean enable)

set sls collector switch, false value will not use sls log collector which may cause OOM default is true

参数:

enable -

setLabel

public void setLabel(String label)

setEnableCgroupMetrics

public void setEnableCgroupMetrics(boolean enable)

enable cgroup metrics collection in docker

参数:

enable -

setCgroupPathPrefix

public void setCgroupPathPrefix(String cgroupPathPrefix)

set cgroup path if the path is not '/sys/fs/cgroup/cpu/'

参数:

cgroupPathPrefix -

setAkkaRemotingAutoRecover

public void setAkkaRemotingAutoRecover(boolean autoRecover)

setEnableHeartbeatLog

public void setEnableHeartbeatLog(boolean enable)

setMapMasterStatusCheckInterval

public void setMapMasterStatusCheckInterval(int interval)

setEnableSecondDelayCycleIntervalMs

public void setEnableSecondDelayCycleIntervalMs(boolean enable)

onApplicationEvent

public void onApplicationEvent(org.springframework.context.event.ApplicationContextEvent event)

指定者:

onApplicationEvent 在接口中 org.springframework.context.ApplicationListener<org.springframework.context.event.ApplicationContextEvent>