public class SimpleApplicationEventMulticaster extends AbstractApplicationEventMulticaster
ApplicationEventMulticaster interface.
Multicasts all events to all registered listeners, leaving it up to
the listeners to ignore events that they are not interested in.
Listeners will usually perform corresponding instanceof
checks on the passed-in event object.
By default, all listeners are invoked in the calling thread. This allows the danger of a rogue listener blocking the entire application, but adds minimal overhead. Specify an alternative task executor to have listeners executed in different threads, for example from a thread pool.
setTaskExecutor(java.util.concurrent.Executor)| Constructor and Description |
|---|
SimpleApplicationEventMulticaster()
Create a new SimpleApplicationEventMulticaster.
|
SimpleApplicationEventMulticaster(BeanFactory beanFactory)
Create a new SimpleApplicationEventMulticaster for the given BeanFactory.
|
| Modifier and Type | Method and Description |
|---|---|
protected ErrorHandler |
getErrorHandler()
Return the current error handler for this multicaster.
|
protected Executor |
getTaskExecutor()
Return the current task executor for this multicaster.
|
protected void |
invokeListener(ApplicationListener listener,
ApplicationEvent event)
Invoke the given listener with the given event.
|
void |
multicastEvent(ApplicationEvent event)
Multicast the given application event to appropriate listeners.
|
void |
setErrorHandler(ErrorHandler errorHandler)
Set the
ErrorHandler to invoke in case an exception is thrown
from a listener. |
void |
setTaskExecutor(Executor taskExecutor)
Set a custom executor (typically a
TaskExecutor)
to invoke each listener with. |
addApplicationListener, addApplicationListenerBean, getApplicationListeners, getApplicationListeners, removeAllListeners, removeApplicationListener, removeApplicationListenerBean, setBeanClassLoader, setBeanFactory, supportsEvent, supportsEventpublic SimpleApplicationEventMulticaster()
public SimpleApplicationEventMulticaster(BeanFactory beanFactory)
public void setTaskExecutor(Executor taskExecutor)
TaskExecutor)
to invoke each listener with.
Default is equivalent to SyncTaskExecutor,
executing all listeners synchronously in the calling thread.
Consider specifying an asynchronous task executor here to not block the caller until all listeners have been executed. However, note that asynchronous execution will not participate in the caller's thread context (class loader, transaction association) unless the TaskExecutor explicitly supports this.
SyncTaskExecutor,
SimpleAsyncTaskExecutorprotected Executor getTaskExecutor()
public void setErrorHandler(ErrorHandler errorHandler)
ErrorHandler to invoke in case an exception is thrown
from a listener.
Default is none, with a listener exception stopping the current multicast and getting propagated to the publisher of the current event. If a task executor is specified, each individual listener exception will get propagated to the executor but won't necessarily stop execution of other listeners.
Consider setting an ErrorHandler implementation that catches
and logs exceptions (a la
TaskUtils.LOG_AND_SUPPRESS_ERROR_HANDLER)
or an implementation that logs exceptions while nevertheless propagating them
(e.g. TaskUtils.LOG_AND_PROPAGATE_ERROR_HANDLER).
protected ErrorHandler getErrorHandler()
public void multicastEvent(ApplicationEvent event)
ApplicationEventMulticasterevent - the event to multicastprotected void invokeListener(ApplicationListener listener, ApplicationEvent event)
listener - the ApplicationListener to invokeevent - the current event to propagate