Class HeartbeatConsumer
- java.lang.Object
-
- org.opennms.minion.heartbeat.consumer.HeartbeatConsumer
-
- All Implemented Interfaces:
MessageConsumer<MinionIdentityDTO,MinionIdentityDTO>
,org.springframework.beans.factory.InitializingBean
public class HeartbeatConsumer extends java.lang.Object implements MessageConsumer<MinionIdentityDTO,MinionIdentityDTO>, org.springframework.beans.factory.InitializingBean
-
-
Constructor Summary
Constructors Constructor Description HeartbeatConsumer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
afterPropertiesSet()
java.util.concurrent.ThreadPoolExecutor
getExecutor()
SinkModule<MinionIdentityDTO,MinionIdentityDTO>
getModule()
void
handleMessage(MinionIdentityDTO minionHandle)
void
setEventSubscriptionService(EventSubscriptionService eventSubscriptionService)
void
shutdown()
-
-
-
Method Detail
-
handleMessage
@Transactional public void handleMessage(MinionIdentityDTO minionHandle)
- Specified by:
handleMessage
in interfaceMessageConsumer<MinionIdentityDTO,MinionIdentityDTO>
-
afterPropertiesSet
public void afterPropertiesSet() throws java.lang.Exception
- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
- Throws:
java.lang.Exception
-
shutdown
public void shutdown()
-
getModule
public SinkModule<MinionIdentityDTO,MinionIdentityDTO> getModule()
- Specified by:
getModule
in interfaceMessageConsumer<MinionIdentityDTO,MinionIdentityDTO>
-
setEventSubscriptionService
public void setEventSubscriptionService(EventSubscriptionService eventSubscriptionService)
-
getExecutor
public java.util.concurrent.ThreadPoolExecutor getExecutor()
-
-