Package jetbrains.buildServer.serverSide.impl.events.async

Class AsyncEventDispatcher

java.lang.Object

jetbrains.buildServer.serverSide.impl.events.async.AsyncEventDispatcher

@Component
public class AsyncEventDispatcher
extends Object

Allows to publish simple events to all subscribed listeners asynchronously with keeping order of execution events per AsyncEventListener.getSyncKey()

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncEventDispatcher.TaskInfo

Field Summary

Fields

Modifier and Type	Field	Description
static String	UNPROCESSED_ASYNC_EVENTS_FILE

Constructor Summary

Constructors

Constructor	Description
AsyncEventDispatcher(EventDispatcher<BuildServerListener> serverEventDispatcher, ServerPaths serverPaths)

Method Summary

Modifier and Type	Method	Description
boolean	isTerminated()
void	publish(AsyncEvent event)
void	shutdown()
void	subscribe(String eventName, AsyncEventListener listener)
void	subscribe(List<String> eventNames, AsyncEventListener listener)
void	unsubscribe(AsyncEventListener eventListener)

Methods inherited from class java.lang.Object

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

Field Detail

UNPROCESSED_ASYNC_EVENTS_FILE

public static final String UNPROCESSED_ASYNC_EVENTS_FILE

See Also:

Constant Field Values

Constructor Detail

AsyncEventDispatcher

public AsyncEventDispatcher(EventDispatcher<BuildServerListener> serverEventDispatcher,
                            ServerPaths serverPaths)

Method Detail

publish

public void publish(AsyncEvent event)

subscribe

public void subscribe(String eventName,
                      AsyncEventListener listener)

subscribe

public void subscribe(List<String> eventNames,
                      AsyncEventListener listener)

unsubscribe

public void unsubscribe(AsyncEventListener eventListener)

shutdown

public void shutdown()

isTerminated

public boolean isTerminated()