public class EventIpcManagerDefaultImpl extends Object implements EventIpcManager, EventIpcBroadcaster, org.springframework.beans.factory.InitializingBean
| Modifier and Type | Class and Description |
|---|---|
static class |
EventIpcManagerDefaultImpl.DiscardTrapsAndSyslogEvents |
| Constructor and Description |
|---|
EventIpcManagerDefaultImpl(com.codahale.metrics.MetricRegistry registry)
Constructor for EventIpcManagerDefaultImpl.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addEventListener(EventListener listener)
Registers an event listener that is interested in all events
|
void |
addEventListener(EventListener listener,
Collection<String> ueis)
Registers an event listener interested in the UEIs in the passed list
|
void |
addEventListener(EventListener listener,
String uei)
Register an event listener interested in the passed UEI.
|
void |
afterPropertiesSet()
afterPropertiesSet
|
void |
broadcastNow(Event event,
boolean synchronous)
Called by eventd to send an event to all interested listeners.
|
EventHandler |
getEventHandler()
getEventHandler
|
int |
getHandlerPoolSize()
getHandlerPoolSize
|
int |
getHandlerQueueLength()
getHandlerQueueLength
|
boolean |
hasEventListener(String uei)
Checks if there is at least one listener for the given uei.
|
void |
removeEventListener(EventListener listener)
Removes a registered event listener
|
void |
removeEventListener(EventListener listener,
Collection<String> ueis)
Removes a registered event listener - the UEI list indicates the list of
events the listener is no more interested in
|
void |
removeEventListener(EventListener listener,
String uei)
Removes a registered event listener.
|
void |
send(Event event)
This method is called to send the event out
|
void |
send(Log eventLog)
send
|
void |
sendNow(Event event)
Asynchronously sends an event to eventd.
|
void |
sendNow(Log eventLog)
Called by a service to send a set of events to other listeners.
|
void |
sendNowSync(Event event)
Synchronously sends an event to eventd.
|
void |
sendNowSync(Log eventLog)
Synchronously sends a set of events to eventd.
|
void |
setEventHandler(EventHandler eventHandler)
setEventHandler
|
void |
setHandlerPoolSize(int handlerPoolSize)
setHandlerPoolSize
|
void |
setHandlerQueueLength(int size)
setHandlerQueueLength
|
public EventIpcManagerDefaultImpl(com.codahale.metrics.MetricRegistry registry)
Constructor for EventIpcManagerDefaultImpl.
public void send(Event event) throws EventProxyException
send in interface EventProxyevent - the event to be sent outEventProxyException - thrown if the send fails for any reasonpublic void send(Log eventLog) throws EventProxyException
send
send in interface EventProxyeventLog - a Log object.EventProxyException - if any.public void sendNow(Event event)
sendNow in interface EventForwarderevent - a Event object.public void sendNow(Log eventLog)
sendNow in interface EventForwardereventLog - a Log object.public void sendNowSync(Event event)
EventForwardersendNowSync in interface EventForwarderevent - a Event object.public void sendNowSync(Log eventLog)
EventForwardersendNowSync in interface EventForwardereventLog - a Log object.public void broadcastNow(Event event, boolean synchronous)
EventIpcBroadcasterbroadcastNow in interface EventIpcBroadcasterevent - a Event object.synchronous - Whether this call should wait for all EventListener
calls to finish before returning.public void addEventListener(EventListener listener)
addEventListener in interface EventSubscriptionServicelistener - a EventListener object.public void addEventListener(EventListener listener, Collection<String> ueis)
addEventListener in interface EventSubscriptionServicelistener - a EventListener object.ueis - a Collection object.public void addEventListener(EventListener listener, String uei)
addEventListener in interface EventSubscriptionServicelistener - a EventListener object.uei - a String object.public void removeEventListener(EventListener listener, Collection<String> ueis)
removeEventListener in interface EventSubscriptionServicelistener - a EventListener object.ueis - a Collection object.public void removeEventListener(EventListener listener, String uei)
removeEventListener in interface EventSubscriptionServicelistener - a EventListener object.uei - a String object.public void removeEventListener(EventListener listener)
removeEventListener in interface EventSubscriptionServicelistener - a EventListener object.public void afterPropertiesSet()
afterPropertiesSet
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanpublic EventHandler getEventHandler()
getEventHandler
EventHandler object.public void setEventHandler(EventHandler eventHandler)
setEventHandler
eventHandler - a EventHandler object.public int getHandlerPoolSize()
getHandlerPoolSize
public void setHandlerPoolSize(int handlerPoolSize)
setHandlerPoolSize
handlerPoolSize - a int.public int getHandlerQueueLength()
getHandlerQueueLength
public void setHandlerQueueLength(int size)
setHandlerQueueLength
size - a int.public boolean hasEventListener(String uei)
EventSubscriptionServicehasEventListener in interface EventSubscriptionServiceuei - the uie to check fortrue iff there is at least one listenerCopyright © 2020. All rights reserved.