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.