org.opennms.netmgt.eventd
Class EventIpcManagerDefaultImpl

java.lang.Object
  org.opennms.netmgt.eventd.EventIpcManagerDefaultImpl

All Implemented Interfaces:

EventIpcBroadcaster, EventIpcManager, EventForwarder, EventProxy, EventSubscriptionService, org.springframework.beans.factory.InitializingBean

public class EventIpcManagerDefaultImpl
extends Object
implements EventIpcManager, EventIpcBroadcaster, org.springframework.beans.factory.InitializingBean

An implementation of the EventIpcManager interface that can be used to communicate between services in the same JVM

Version:

$Id: $

Author:

Sowmya Nataraj , OpenNMS.org , Sowmya Nataraj , OpenNMS.org

Constructor Summary

EventIpcManagerDefaultImpl()
Constructor for EventIpcManagerDefaultImpl.

Method Summary

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) Called by eventd to send an event to all interested listeners.
EventHandler	getEventHandler() getEventHandler
EventIpcManagerProxy	getEventIpcManagerProxy() getEventIpcManagerProxy
int	getHandlerPoolSize() getHandlerPoolSize
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) 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 other listeners.
void	setEventHandler(EventHandler eventHandler) setEventHandler
void	setEventIpcManagerProxy(EventIpcManagerProxy eventIpcManagerProxy) setEventIpcManagerProxy
void	setHandlerPoolSize(int handlerPoolSize) setHandlerPoolSize

Methods inherited from class java.lang.Object

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

Constructor Detail

EventIpcManagerDefaultImpl

public EventIpcManagerDefaultImpl()

Constructor for EventIpcManagerDefaultImpl.

Method Detail

send

public void send(Event event)
          throws EventProxyException

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

send

Specified by:

send in interface EventProxy

Parameters:

eventLog - a Log object.

Throws:

EventProxyException - if any.

sendNow

public void sendNow(Event event)

Called by a service to send an event to eventd Called by a service to send an event to other listeners.

Specified by:

sendNow in interface EventForwarder

Parameters:

event - a Event object.

sendNow

public void sendNow(Log eventLog)

Called by a service to send a set of events to other listeners. Creates a new event handler for the event log and queues it to the event handler thread pool.

Specified by:

sendNow in interface EventForwarder

Parameters:

eventLog - a Log object.

broadcastNow

public void broadcastNow(Event event)

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

Specified by:

broadcastNow in interface EventIpcBroadcaster

Parameters:

event - a Event object.

addEventListener

public void addEventListener(EventListener listener)

Registers an event listener that is interested in all events Register an event listener that is interested in all events. Removes this listener from any UEI-specific matches.

Specified by:

addEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

addEventListener

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

Registers an event listener interested in the UEIs in the passed list Register 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)

Register an event listener interested in the passed UEI.

Specified by:

addEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

uei - a String object.

removeEventListener

public 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 Removes a registered event listener. The UEI list indicates the list of events the listener is no more interested in. Note: The listener thread for this listener is not stopped until the 'removeEventListener(EventListener listener)' method is called.

Specified by:

removeEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

ueis - a Collection object.

removeEventListener

public void removeEventListener(EventListener listener,
                                String uei)

Removes a registered event listener. The UEI indicates one the listener is no more interested in. Note: The listener thread for this listener is not stopped until the 'removeEventListener(EventListener listener)' method is called.

Specified by:

removeEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

uei - a String object.

removeEventListener

public void removeEventListener(EventListener listener)

Removes a registered event listener Removes a registered event listener. Note: Only this method stops the listener thread for the listener passed.

Specified by:

removeEventListener in interface EventSubscriptionService

Parameters:

listener - a EventListener object.

afterPropertiesSet

public void afterPropertiesSet()

afterPropertiesSet

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

getEventHandler

public EventHandler getEventHandler()

getEventHandler

Returns:

a EventHandler object.

setEventHandler

public void setEventHandler(EventHandler eventHandler)

setEventHandler

Parameters:

eventHandler - a EventHandler object.

getHandlerPoolSize

public int getHandlerPoolSize()

getHandlerPoolSize

Returns:

a int.

setHandlerPoolSize

public void setHandlerPoolSize(int handlerPoolSize)

setHandlerPoolSize

Parameters:

handlerPoolSize - a int.

getEventIpcManagerProxy

public EventIpcManagerProxy getEventIpcManagerProxy()

getEventIpcManagerProxy

Returns:

a EventIpcManagerProxy object.

setEventIpcManagerProxy

public void setEventIpcManagerProxy(EventIpcManagerProxy eventIpcManagerProxy)

setEventIpcManagerProxy

Parameters:

eventIpcManagerProxy - a EventIpcManagerProxy object.