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