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
Exception
public 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 © 2021. All rights reserved.