org.openecomp.dcae.apod.analytics.tca.worker

Class TCADMaaPMRSubscriberJob

java.lang.Object

org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPMRSubscriberJob

All Implemented Interfaces:

org.quartz.Job

@DisallowConcurrentExecution
 @PersistJobDataAfterExecution
public class TCADMaaPMRSubscriberJob
extends Object
implements org.quartz.Job

Quartz Job which polls DMaaP MR VES Collector Topic for messages and writes them to a given CDAP Stream

Author:

Rajiv Singla. Creation Date: 10/24/2016.

Constructor Summary

Constructors

Constructor and Description
TCADMaaPMRSubscriberJob()

Method Summary

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TCADMaaPMRSubscriberJob

public TCADMaaPMRSubscriberJob()

Method Detail

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)
             throws org.quartz.JobExecutionException

Specified by:

execute in interface org.quartz.Job

Throws:

org.quartz.JobExecutionException