Package org.opennms.netmgt.dao.mock

Class MockEventIpcManager

java.lang.Object

org.opennms.netmgt.dao.mock.MockEventIpcManager

All Implemented Interfaces:

EventForwarder, EventIpcBroadcaster, EventIpcManager, EventProxy, EventSubscriptionService

public class MockEventIpcManager
extends Object
implements EventForwarder, EventProxy, EventIpcManager, EventIpcBroadcaster

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MockEventIpcManager.EmptyEventConfDao	This class implements EventConfDao but every call returns null.
static interface	MockEventIpcManager.SendNowHook

Constructor Summary

Constructors

Constructor	Description
MockEventIpcManager()

Method Summary

Modifier and Type	Method	Description
void	addEventListener(EventListener listener)	Registers an event listener that is interested in all events
void	addEventListener(EventListener listener, String uei)	Registers an event listener interested in the passed UEI
void	addEventListener(EventListener listener, Collection<String> ueis)	Registers an event listener interested in the UEIs in the passed list
void	broadcastNow(Event event)
void	broadcastNow(Event event, boolean synchronous)	Called by eventd to send an event to all interested listeners.
void	finishProcessingEvents()
EventAnticipator	getEventAnticipator()
EventdConfig	getEventdConfig()
int	getEventListenerCount()
int	getNumSchedulerTheads()
MockEventIpcManager.SendNowHook	getSendNowHook()
boolean	hasEventListener(String uei)	Checks if there is at least one listener for the given uei.
boolean	isSynchronous()
void	removeEventListener(EventListener listener)	Removes a registered event listener
void	removeEventListener(EventListener listener, String uei)	Removes a registered event listener - the UEI indicates an event the listener is no more interested in
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	reset()	Resets the event listeners and resets the event anticipator.
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)	Asynchronously sends an event to eventd.
void	sendNow(Event event, boolean synchronous)
void	sendNow(Log eventLog)	Asynchronously sends a set of events to eventd.
void	sendNowSync(Event event)	Synchronously sends an event to eventd.
void	sendNowSync(Log eventLog)	Synchronously sends 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)

Methods inherited from class java.lang.Object

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

Constructor Detail

MockEventIpcManager

public MockEventIpcManager()

Method Detail

addEventListener

public void addEventListener(EventListener listener)

Description copied from interface: EventSubscriptionService

Registers an event listener that is interested in all events

Specified by:

addEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

addEventListener

public void addEventListener(EventListener listener,
                             Collection<String> ueis)

Description copied from interface: EventSubscriptionService

Registers an event listener interested in the UEIs in the passed list

Specified by:

addEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

ueis - a Collection object.

addEventListener

public void addEventListener(EventListener listener,
                             String uei)

Description copied from interface: EventSubscriptionService

Registers an event listener interested in the passed UEI

Specified by:

addEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

uei - a String object.

getEventListenerCount

public int getEventListenerCount()

broadcastNow

public void broadcastNow(Event event)

broadcastNow

public void broadcastNow(Event event,
                         boolean synchronous)

Description copied from interface: EventIpcBroadcaster

Called by eventd to send an event to all interested listeners.

Specified by:

broadcastNow in interface EventIpcBroadcaster

Parameters:

event - a Event object.

synchronous - Whether this call should wait for all EventListener calls to finish before returning.

setEventWriter

public void setEventWriter(EventWriter eventWriter)

getEventAnticipator

public EventAnticipator getEventAnticipator()

setEventExpander

public void setEventExpander(EventExpander expander)

setEventAnticipator

public void setEventAnticipator(EventAnticipator anticipator)

removeEventListener

public void removeEventListener(EventListener listener)

Description copied from interface: EventSubscriptionService

Removes a registered event listener

Specified by:

removeEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

removeEventListener

public void removeEventListener(EventListener listener,
                                Collection<String> ueis)

Description copied from interface: EventSubscriptionService

Removes a registered event listener - the UEI list indicates the list of events the listener is no more interested in

Specified by:

removeEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

ueis - a Collection object.

removeEventListener

public void removeEventListener(EventListener listener,
                                String uei)

Description copied from interface: EventSubscriptionService

Removes a registered event listener - the UEI indicates an event the listener is no more interested in

Specified by:

removeEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

uei - a String object.

setEventDelay

public void setEventDelay(int millis)

sendEventToListeners

public void sendEventToListeners(Event event)

Parameters:

event -

setSynchronous

public void setSynchronous(boolean syncState)

isSynchronous

public boolean isSynchronous()

setSendNowHook

public void setSendNowHook(MockEventIpcManager.SendNowHook hook)

getSendNowHook

public MockEventIpcManager.SendNowHook getSendNowHook()

setNumSchedulerThreads

public void setNumSchedulerThreads(int numThreads)

getNumSchedulerTheads

public int getNumSchedulerTheads()

sendNow

public void sendNow(Event event)

Description copied from interface: EventForwarder

Asynchronously sends an event to eventd.

Specified by:

sendNow in interface EventForwarder

Parameters:

event - a Event object.

sendNow

public void sendNow(Event event,
                    boolean synchronous)

sendNow

public void sendNow(Log eventLog)

Description copied from interface: EventForwarder

Asynchronously sends a set of events to eventd.

Specified by:

sendNow in interface EventForwarder

Parameters:

eventLog - a Log object.

sendNowSync

public void sendNowSync(Event event)

Description copied from interface: EventForwarder

Synchronously sends an event to eventd.

Specified by:

sendNowSync in interface EventForwarder

Parameters:

event - a Event object.

sendNowSync

public void sendNowSync(Log eventLog)

Description copied from interface: EventForwarder

Synchronously sends a set of events to eventd.

Specified by:

sendNowSync in interface EventForwarder

Parameters:

eventLog - a Log object.

finishProcessingEvents

public void finishProcessingEvents()

getEventdConfig

public EventdConfig getEventdConfig()

setEventdConfig

public void setEventdConfig(EventdConfig eventdConfig)

setDataSource

public void setDataSource(DataSource instance)

reset

public void reset()

Resets the event listeners and resets the event anticipator.

send

public void send(Event event)
          throws EventProxyException

Description copied from interface: EventProxy

This method is called to send the event out

Specified by:

send in interface EventProxy

Parameters:

event - the event to be sent out

Throws:

EventProxyException - thrown if the send fails for any reason

send

public void send(Log eventLog)
          throws EventProxyException

Description copied from interface: EventProxy

This method is called to send an event log containing multiple events out

Specified by:

send in interface EventProxy

Parameters:

eventLog - the events to be sent out

Throws:

EventProxyException - thrown if the send fails for any reason

hasEventListener

public boolean hasEventListener(String uei)

Description copied from interface: EventSubscriptionService

Checks if there is at least one listener for the given uei.

Specified by:

hasEventListener in interface EventSubscriptionService

Parameters:

uei - the uie to check for

Returns:

true iff there is at least one listener