public class EventIpcBroadcastProcessor extends Object implements EventProcessor, org.springframework.beans.factory.InitializingBean
Constructor and Description |
---|
EventIpcBroadcastProcessor(com.codahale.metrics.MetricRegistry registry) |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet()
afterPropertiesSet
|
EventIpcBroadcaster |
getEventIpcBroadcaster()
getEventIpcBroadcaster
|
void |
process(Log eventLog)
If synchronous mode is not specified, the event is broadcasted
asynchronously by default.
|
void |
process(Log eventLog,
boolean synchronous) |
void |
setEventIpcBroadcaster(EventIpcBroadcaster eventIpcManager)
setEventIpcBroadcaster
|
public EventIpcBroadcastProcessor(com.codahale.metrics.MetricRegistry registry)
public void afterPropertiesSet() throws IllegalStateException
afterPropertiesSet
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
IllegalStateException
- if any.public void process(Log eventLog) throws EventProcessorException
process
in interface EventProcessor
EventProcessorException
public void process(Log eventLog, boolean synchronous) throws EventProcessorException
process
in interface EventProcessor
EventProcessorException
public EventIpcBroadcaster getEventIpcBroadcaster()
getEventIpcBroadcaster
EventIpcBroadcaster
object.public void setEventIpcBroadcaster(EventIpcBroadcaster eventIpcManager)
setEventIpcBroadcaster
eventIpcManager
- a EventIpcBroadcaster
object.Copyright © 2021. All rights reserved.