| Modifier and Type | Method and Description | 
|---|---|
void | 
DefaultEventForwarder.sendNow(Log eventLog)
Send the incoming  
Log message into the Camel route
 specified by the DefaultDispatcher.m_endpointUri property. | 
void | 
DefaultEventForwarder.sendNowSync(Log eventLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
EventDispatcherImpl.sendNow(Log eventLog)  | 
void | 
EventDispatcherImpl.sendNowSync(Log eventLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
AggregationPolicy<Event,Log,Log> | 
EventSinkModule.getAggregationPolicy()  | 
AggregationPolicy<Event,Log,Log> | 
EventSinkModule.getAggregationPolicy()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Log> | 
TransactionAwareEventForwarder.PendingEventsHolder.consumePendingEvents()  | 
List<Log> | 
TransactionAwareEventForwarder.PendingEventsHolder.getPendingEvents()  | 
List<Log> | 
TransactionAwareEventForwarder.requestPendingEventsList()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TransactionAwareEventForwarder.sendNow(Log eventLog)  | 
void | 
TransactionAwareEventForwarder.sendNowSync(Log eventLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TransactionAwareEventForwarder.releasePendingEventsList(List<Log> pendingEvents)  | 
void | 
TransactionAwareEventForwarder.PendingEventsHolder.setPendingEventsList(List<Log> pendingEvents)  | 
| Constructor and Description | 
|---|
PendingEventsHolder(List<Log> pendingEvents)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MockEventWriter.process(Log eventLog)  | 
void | 
MockEventWriter.process(Log eventLog,
       boolean synchronous)  | 
void | 
MockEventIpcManager.send(Log eventLog)  | 
void | 
AbstractMockDao.NullEventForwarder.sendNow(Log eventLog)  | 
void | 
MockEventIpcManager.sendNow(Log eventLog)  | 
void | 
AbstractMockDao.NullEventForwarder.sendNowSync(Log eventLog)  | 
void | 
MockEventIpcManager.sendNowSync(Log eventLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
org.opennms.netmgt.eventd.DefaultEventHandlerImpl.EventHandlerRunnable | 
DefaultEventHandlerImpl.createRunnable(Log eventLog)  | 
org.opennms.netmgt.eventd.DefaultEventHandlerImpl.EventHandlerRunnable | 
DefaultEventHandlerImpl.createRunnable(Log eventLog,
              boolean synchronous)  | 
void | 
EventExpander.process(Log eventLog)  | 
void | 
EventExpander.process(Log eventLog,
       boolean synchronous)
Event expansion is always synchronous so this method just
 delegates to  
EventExpander.process(Log). | 
void | 
EventIpcManagerDefaultImpl.send(Log eventLog)
send 
 | 
void | 
EventIpcManagerDefaultImpl.sendNow(Log eventLog)
Called by a service to send a set of events to other listeners. 
 | 
void | 
EventIpcManagerDefaultImpl.sendNowSync(Log eventLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HibernateEventWriter.process(Log eventLog)  | 
void | 
EventParmRegexFilterProcessor.process(Log eventLog)  | 
void | 
EventIpcBroadcastProcessor.process(Log eventLog)
If synchronous mode is not specified, the event is broadcasted 
 asynchronously by default. 
 | 
void | 
HibernateEventWriter.process(Log eventLog,
       boolean synchronous)
Event writing is always synchronous so this method just 
 delegates to  
HibernateEventWriter.process(Log). | 
void | 
EventParmRegexFilterProcessor.process(Log eventLog,
       boolean synchronous)
This processor is always synchronous so this method just 
 delegates to  
EventParmRegexFilterProcessor.process(Log). | 
void | 
EventIpcBroadcastProcessor.process(Log eventLog,
       boolean synchronous)  | 
| Modifier and Type | Method and Description | 
|---|---|
SinkModule<Event,Log> | 
EventSinkConsumer.getModule()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
EventSinkConsumer.handleMessage(Log eventLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
Runnable | 
EventHandler.createRunnable(Log eventLog)
Create a Runnable to handle the passed-in event Log. 
 | 
Runnable | 
EventHandler.createRunnable(Log eventLog,
              boolean synchronous)
Create a Runnable to handle the passed-in event Log. 
 | 
void | 
EventProcessor.process(Log eventLog)  | 
void | 
EventProcessor.process(Log eventLog,
       boolean synchronous)  | 
void | 
EventProxy.send(Log eventLog)
This method is called to send an event log containing multiple events out 
 | 
void | 
EventForwarder.sendNow(Log eventLog)
Asynchronously sends a set of events to eventd. 
 | 
void | 
EventForwarder.sendNowSync(Log eventLog)
Synchronously sends a set of events to eventd. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TcpEventProxy.send(Log eventLog)
Deprecated.  
This method is called to send an event log containing multiple events
 out. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Log | 
EventBuilder.getLog()  | 
| Modifier and Type | Method and Description | 
|---|---|
Log | 
SyslogSinkConsumer.toEventLog(SyslogMessageLogDTO messageLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ThresholdingEventProxyImpl.send(Log eventLog)  | 
| Modifier and Type | Method and Description | 
|---|---|
Log | 
ObjectFactory.createLog()
Create an instance of  
Log | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Log.addAllEvents(Log log)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
EventForwarderQueueImpl.sendNow(Log eventLog)  | 
void | 
EventForwarderQueueImpl.sendNowSync(Log eventLog)
Call  
AggregatingMessageProducer.dispatch(Object) to synchronously
 dispatch the events. | 
Copyright © 2021. All rights reserved.