public class EventSinkConsumer extends Object implements MessageConsumer<Event,Log>
| Constructor and Description |
|---|
EventSinkConsumer() |
| Modifier and Type | Method and Description |
|---|---|
SinkModule<Event,Log> |
getModule() |
void |
handleMessage(Log eventLog) |
void |
init() |
void |
setconfig(EventdConfig m_config) |
void |
setEventForwarder(EventForwarder eventForwarder) |
void |
setMessageConsumerManager(MessageConsumerManager messageConsumerManager) |
@PostConstruct public void init() throws Exception
Exceptionpublic SinkModule<Event,Log> getModule()
getModule in interface MessageConsumer<Event,Log>public void handleMessage(Log eventLog)
handleMessage in interface MessageConsumer<Event,Log>public void setconfig(EventdConfig m_config)
public void setMessageConsumerManager(MessageConsumerManager messageConsumerManager)
public void setEventForwarder(EventForwarder eventForwarder)
Copyright © 2022. All rights reserved.