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

Class TCADMaaPMockSubscriberWorker

java.lang.Object

co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

co.cask.cdap.internal.api.AbstractPluginConfigurable<co.cask.cdap.api.worker.WorkerConfigurer>

co.cask.cdap.api.worker.AbstractWorker

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

All Implemented Interfaces:

co.cask.cdap.api.ProgramLifecycle<co.cask.cdap.api.worker.WorkerContext>, co.cask.cdap.api.worker.Worker, Runnable

public class TCADMaaPMockSubscriberWorker
extends co.cask.cdap.api.worker.AbstractWorker

CDAP Worker which mocks fetching VES Messages from DMaaP MR topic. The mock instead of making DMaaP MR calls will actually take messages from file and send them to stream at subscriber polling interval TODO: To be removed before going to production - only for testing purposes

Author:

Rajiv Singla. Creation Date: 11/4/2016.

Constructor Summary

Constructors

Constructor and Description
TCADMaaPMockSubscriberWorker(String tcaSubscriberOutputStreamName)

Method Summary

Modifier and Type	Method and Description
void	configure()
void	initialize(co.cask.cdap.api.worker.WorkerContext context)
void	run()
void	stop()

Methods inherited from class co.cask.cdap.api.worker.AbstractWorker

configure, destroy, getConfigurer, getContext, setDescription, setInstances, setName, setProperties, setResources

Methods inherited from class co.cask.cdap.internal.api.AbstractPluginConfigurable

usePlugin, usePlugin, usePluginClass, usePluginClass

Methods inherited from class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

addDatasetModule, addDatasetType, addStream, addStream, createDataset, createDataset, createDataset, createDataset

Methods inherited from class java.lang.Object

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

Constructor Detail

TCADMaaPMockSubscriberWorker

public TCADMaaPMockSubscriberWorker(String tcaSubscriberOutputStreamName)

Method Detail

configure

public void configure()

Overrides:

configure in class co.cask.cdap.api.worker.AbstractWorker

initialize

public void initialize(co.cask.cdap.api.worker.WorkerContext context)
                throws Exception

Specified by:

initialize in interface co.cask.cdap.api.ProgramLifecycle<co.cask.cdap.api.worker.WorkerContext>

Overrides:

initialize in class co.cask.cdap.api.worker.AbstractWorker

Throws:

Exception

run

public void run()

stop

public void stop()

Specified by:

stop in interface co.cask.cdap.api.worker.Worker

Overrides:

stop in class co.cask.cdap.api.worker.AbstractWorker