public class MockEventIpcManager extends Object implements EventForwarder, EventProxy, EventIpcManager, EventIpcBroadcaster
| Modifier and Type | Class and Description |
|---|---|
static class |
MockEventIpcManager.EmptyEventConfDao
This class implements
EventConfDao but every call returns null. |
static interface |
MockEventIpcManager.SendNowHook |
| Constructor and Description |
|---|
MockEventIpcManager() |
| 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)
Registers an event listener interested in the passed UEI
|
void |
broadcastNow(Event event)
Called by eventd to send an event to all interested listeners.
|
void |
finishProcessingEvents() |
EventAnticipator |
getEventAnticipator() |
EventdConfig |
getEventdConfig() |
int |
getNumSchedulerTheads() |
MockEventIpcManager.SendNowHook |
getSendNowHook() |
boolean |
isSynchronous() |
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 - the UEI indicates an event the
listener is no more interested in
|
void |
reset() |
void |
send(Event event)
This method is called to send the event out
|
void |
send(Log eventLog)
This method is called to send an event log containing multiple events out
|
void |
sendEventToListeners(Event event) |
void |
sendNow(Event event)
Called by a service to send an event to eventd
|
void |
sendNow(Log eventLog)
Called by a service to send a set of events to eventd
|
void |
setDataSource(DataSource instance) |
void |
setEventAnticipator(EventAnticipator anticipator) |
void |
setEventdConfig(EventdConfig eventdConfig) |
void |
setEventDelay(int millis) |
void |
setEventExpander(EventExpander expander) |
void |
setEventWriter(EventWriter eventWriter) |
void |
setNumSchedulerThreads(int numThreads) |
void |
setSendNowHook(MockEventIpcManager.SendNowHook hook) |
void |
setSynchronous(boolean syncState) |
public void addEventListener(EventListener listener)
EventSubscriptionServiceaddEventListener in interface EventSubscriptionServicelistener - a EventListener object.public void addEventListener(EventListener listener, Collection<String> ueis)
EventSubscriptionServiceaddEventListener in interface EventSubscriptionServicelistener - a EventListener object.ueis - a Collection object.public void addEventListener(EventListener listener, String uei)
EventSubscriptionServiceaddEventListener in interface EventSubscriptionServicelistener - a EventListener object.uei - a String object.public void broadcastNow(Event event)
EventIpcBroadcasterbroadcastNow in interface EventIpcBroadcasterevent - a Event object.public void setEventWriter(EventWriter eventWriter)
public EventAnticipator getEventAnticipator()
public void setEventExpander(EventExpander expander)
public void setEventAnticipator(EventAnticipator anticipator)
public void removeEventListener(EventListener listener)
EventSubscriptionServiceremoveEventListener in interface EventSubscriptionServicelistener - a EventListener object.public void removeEventListener(EventListener listener, Collection<String> ueis)
EventSubscriptionServiceremoveEventListener in interface EventSubscriptionServicelistener - a EventListener object.ueis - a Collection object.public void removeEventListener(EventListener listener, String uei)
EventSubscriptionServiceremoveEventListener in interface EventSubscriptionServicelistener - a EventListener object.uei - a String object.public void setEventDelay(int millis)
public void sendEventToListeners(Event event)
event - public void setSynchronous(boolean syncState)
public boolean isSynchronous()
public void setSendNowHook(MockEventIpcManager.SendNowHook hook)
public MockEventIpcManager.SendNowHook getSendNowHook()
public void setNumSchedulerThreads(int numThreads)
public int getNumSchedulerTheads()
public void sendNow(Event event)
EventForwardersendNow in interface EventForwarderevent - a Event object.public void sendNow(Log eventLog)
EventForwardersendNow in interface EventForwardereventLog - a Log object.public void finishProcessingEvents()
public EventdConfig getEventdConfig()
public void setEventdConfig(EventdConfig eventdConfig)
public void setDataSource(DataSource instance)
public void reset()
public void send(Event event) throws EventProxyException
EventProxysend in interface EventProxyevent - the event to be sent outEventProxyException - thrown if the send fails for any reasonpublic void send(Log eventLog) throws EventProxyException
EventProxysend in interface EventProxyeventLog - the events to be sent outEventProxyException - thrown if the send fails for any reasonCopyright © 2015. All rights reserved.