Class EventDispatcherImpl
- java.lang.Object
-
- org.opennms.features.events.sink.dispatcher.EventDispatcherImpl
-
- All Implemented Interfaces:
EventForwarder
public class EventDispatcherImpl extends java.lang.Object implements EventForwarder
This Class is used to send events from minion, not exposed on OpenNMS.
-
-
Constructor Summary
Constructors Constructor Description EventDispatcherImpl(MessageDispatcherFactory messageDispatcherFactory, EventdConfig eventdConfig)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AsyncDispatcher<Event>
getAsyncDispatcher()
void
sendNow(Event event)
Asynchronously sends an event to eventd.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.
-
-
-
Constructor Detail
-
EventDispatcherImpl
public EventDispatcherImpl(MessageDispatcherFactory messageDispatcherFactory, EventdConfig eventdConfig)
-
-
Method Detail
-
sendNow
public void sendNow(Event event)
Description copied from interface:EventForwarder
Asynchronously sends an event to eventd.- Specified by:
sendNow
in interfaceEventForwarder
- Parameters:
event
- aEvent
object.
-
sendNow
public void sendNow(Log eventLog)
Description copied from interface:EventForwarder
Asynchronously sends a set of events to eventd.- Specified by:
sendNow
in interfaceEventForwarder
- Parameters:
eventLog
- aLog
object.
-
sendNowSync
public void sendNowSync(Event event)
Description copied from interface:EventForwarder
Synchronously sends an event to eventd.- Specified by:
sendNowSync
in interfaceEventForwarder
- Parameters:
event
- aEvent
object.
-
sendNowSync
public void sendNowSync(Log eventLog)
Description copied from interface:EventForwarder
Synchronously sends a set of events to eventd.- Specified by:
sendNowSync
in interfaceEventForwarder
- Parameters:
eventLog
- aLog
object.
-
getAsyncDispatcher
public AsyncDispatcher<Event> getAsyncDispatcher()
-
-