com.dtp.adapter.common

类 AbstractDtpAdapter

java.lang.Object

com.dtp.adapter.common.AbstractDtpAdapter

所有已实现的接口:

DtpAdapter, MetricsAware, EventListener, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>, org.springframework.context.event.GenericApplicationListener, org.springframework.context.event.SmartApplicationListener, org.springframework.core.Ordered

public abstract class AbstractDtpAdapter
extends Object
implements DtpAdapter, org.springframework.context.event.GenericApplicationListener

AbstractDtpAdapter related

从以下版本开始:

1.0.6

作者:

yanhom, dragon-zhang

字段概要

字段

限定符和类型	字段和说明
protected Map<String,ExecutorWrapper>	executors

从接口继承的字段 org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

构造器概要

构造器

构造器和说明
AbstractDtpAdapter()

方法概要

限定符和类型	方法和说明
protected void	doRefresh(ExecutorWrapper executorWrapper, List<com.dtp.common.entity.NotifyPlatform> platforms, com.dtp.common.entity.TpExecutorProps props)
Map<String,ExecutorWrapper>	getExecutorWrappers() Get executor wrappers.
List<com.dtp.common.entity.ThreadPoolStats>	getMultiPoolStats() Get multi thread pool stats.
protected com.dtp.common.entity.TpMainFields	getTpMainFields(ExecutorWrapper executorWrapper, com.dtp.common.entity.TpExecutorProps props)
protected void	initialize()
void	initNotifyItems(String poolName, ExecutorWrapper executorWrapper)
void	onApplicationEvent(org.springframework.context.ApplicationEvent event)
void	refresh(String name, ExecutorWrapper executorWrapper, List<com.dtp.common.entity.NotifyPlatform> platforms, com.dtp.common.entity.TpExecutorProps props)
void	refresh(String name, List<com.dtp.common.entity.TpExecutorProps> propsList, List<com.dtp.common.entity.NotifyPlatform> platforms)
void	register(String poolName, ThreadPoolExecutor threadPoolExecutor)
boolean	supportsEventType(org.springframework.core.ResolvableType resolvableType)

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

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

从接口继承的方法 com.dtp.adapter.common.DtpAdapter

containsInvalidParams, getExecutorWrapper, refresh

从接口继承的方法 com.dtp.core.support.MetricsAware

getPoolStats

从接口继承的方法 org.springframework.context.event.GenericApplicationListener

supportsEventType

从接口继承的方法 org.springframework.context.event.SmartApplicationListener

getListenerId, getOrder, supportsSourceType

从接口继承的方法 org.springframework.context.ApplicationListener

forPayload

字段详细资料

executors

protected final Map<String,ExecutorWrapper> executors

构造器详细资料

AbstractDtpAdapter

public AbstractDtpAdapter()

方法详细资料

supportsEventType

public boolean supportsEventType(org.springframework.core.ResolvableType resolvableType)

指定者:

supportsEventType 在接口中 org.springframework.context.event.GenericApplicationListener

onApplicationEvent

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

指定者:

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

initialize

protected void initialize()

register

public void register(String poolName,
                     ThreadPoolExecutor threadPoolExecutor)

getExecutorWrappers

public Map<String,ExecutorWrapper> getExecutorWrappers()

从接口复制的说明: DtpAdapter

Get executor wrappers.

指定者:

getExecutorWrappers 在接口中 DtpAdapter

返回:

executors

getMultiPoolStats

public List<com.dtp.common.entity.ThreadPoolStats> getMultiPoolStats()

Get multi thread pool stats.

指定者:

getMultiPoolStats 在接口中 MetricsAware

返回:

thead pools stats

initNotifyItems

public void initNotifyItems(String poolName,
                            ExecutorWrapper executorWrapper)

refresh

public void refresh(String name,
                    List<com.dtp.common.entity.TpExecutorProps> propsList,
                    List<com.dtp.common.entity.NotifyPlatform> platforms)

refresh

public void refresh(String name,
                    ExecutorWrapper executorWrapper,
                    List<com.dtp.common.entity.NotifyPlatform> platforms,
                    com.dtp.common.entity.TpExecutorProps props)

getTpMainFields

protected com.dtp.common.entity.TpMainFields getTpMainFields(ExecutorWrapper executorWrapper,
                                                             com.dtp.common.entity.TpExecutorProps props)

doRefresh

protected void doRefresh(ExecutorWrapper executorWrapper,
                         List<com.dtp.common.entity.NotifyPlatform> platforms,
                         com.dtp.common.entity.TpExecutorProps props)