程序包 com.alibaba.nacos.common.trace.publisher

类 TraceEventPublisher

java.lang.Object

java.lang.Thread

com.alibaba.nacos.common.trace.publisher.TraceEventPublisher

所有已实现的接口:

Closeable, EventPublisher, ShardedEventPublisher, Runnable

public class TraceEventPublisher
extends Thread
implements ShardedEventPublisher

Event publisher for trace event.

作者:

yanda

嵌套类概要

从类继承的嵌套类/接口 java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

字段概要

从类继承的字段 java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

构造器概要

构造器

构造器	说明
TraceEventPublisher()

方法概要

修饰符和类型	方法	说明
void	addSubscriber(Subscriber subscriber)	Add listener.
void	addSubscriber(Subscriber subscriber, Class<? extends Event> subscribeType)	Add listener for default share publisher.
long	currentEventSize()	The number of currently staged events.
String	getStatus()
void	init(Class<? extends Event> type, int bufferSize)	Initializes the event publisher.
void	notifySubscriber(Subscriber subscriber, Event event)	Notify listener.
boolean	publish(Event event)	publish event.
void	removeSubscriber(Subscriber subscriber)	Remove listener.
void	removeSubscriber(Subscriber subscriber, Class<? extends Event> subscribeType)	Remove listener for default share publisher.
void	run()
void	shutdown()	Shutdown the Resources, such as Thread Pool.

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

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

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

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

构造器详细资料

TraceEventPublisher

public TraceEventPublisher()

方法详细资料

init

public void init(Class<? extends Event> type,
 int bufferSize)

从接口复制的说明: EventPublisher

Initializes the event publisher.

指定者:

init 在接口中 EventPublisher

参数:

type - >

bufferSize - Message staging queue size

currentEventSize

public long currentEventSize()

从接口复制的说明: EventPublisher

The number of currently staged events.

指定者:

currentEventSize 在接口中 EventPublisher

返回:

event size

addSubscriber

public void addSubscriber(Subscriber subscriber)

从接口复制的说明: EventPublisher

Add listener.

指定者:

addSubscriber 在接口中 EventPublisher

参数:

subscriber - Subscriber

addSubscriber

public void addSubscriber(Subscriber subscriber,
 Class<? extends Event> subscribeType)

从接口复制的说明: ShardedEventPublisher

Add listener for default share publisher.

指定者:

addSubscriber 在接口中 ShardedEventPublisher

参数:

subscriber - Subscriber

subscribeType - subscribe event type, such as slow event or general event.

removeSubscriber

public void removeSubscriber(Subscriber subscriber)

从接口复制的说明: EventPublisher

Remove listener.

指定者:

removeSubscriber 在接口中 EventPublisher

参数:

subscriber - Subscriber

removeSubscriber

public void removeSubscriber(Subscriber subscriber,
 Class<? extends Event> subscribeType)

从接口复制的说明: ShardedEventPublisher

Remove listener for default share publisher.

指定者:

removeSubscriber 在接口中 ShardedEventPublisher

参数:

subscriber - Subscriber

subscribeType - subscribe event type, such as slow event or general event.

publish

public boolean publish(Event event)

从接口复制的说明: EventPublisher

publish event.

指定者:

publish 在接口中 EventPublisher

参数:

event - Event

返回:

publish event is success

notifySubscriber

public void notifySubscriber(Subscriber subscriber,
 Event event)

从接口复制的说明: EventPublisher

Notify listener.

指定者:

notifySubscriber 在接口中 EventPublisher

参数:

subscriber - Subscriber

event - Event

shutdown

public void shutdown()
              throws com.alibaba.nacos.api.exception.NacosException

从接口复制的说明: Closeable

Shutdown the Resources, such as Thread Pool.

指定者:

shutdown 在接口中 Closeable

抛出:

com.alibaba.nacos.api.exception.NacosException - exception.

run

public void run()

指定者:

run 在接口中 Runnable

覆盖:

run 在类中 Thread

getStatus

public String getStatus()