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 © 2019. All rights reserved.