com.gigaspaces.dih.consumer.web

Class GSConsumerHandler

java.lang.Object

com.gigaspaces.dih.consumer.web.GSConsumerHandler

public class GSConsumerHandler
extends Object

Constructor Summary

Constructors

Constructor and Description
GSConsumerHandler(String pipelineName, int port, GSKafkaConsumerThread runnable)

Method Summary

Modifier and Type	Method and Description
void	clearPipelineTables(List<String> typesList)
String	delete()
void	deletePipelineCdcInfo(String pipelineName)
void	destroy()
GSKafkaConsumerStatusEnum	getConsumerStatus()
String	getKafkaBoostrap()
int	getStatusCode()
int	getTotalOperation()
boolean	hasKafkaDeltaInTopic()
void	init(ISpaceProxy gigaSpace, String puName)
boolean	isAlive()
void	setConsumerStatus(GSKafkaConsumerStatusEnum newStatus)
void	startDataIngestion()
void	stopDataIngestion()

Methods inherited from class java.lang.Object

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

Constructor Detail

GSConsumerHandler

public GSConsumerHandler(String pipelineName,
                         int port,
                         GSKafkaConsumerThread runnable)

Method Detail

init

public void init(ISpaceProxy gigaSpace,
                 String puName)
          throws IOException

Throws:

IOException

startDataIngestion

public void startDataIngestion()

stopDataIngestion

public void stopDataIngestion()

isAlive

public boolean isAlive()

getStatusCode

public int getStatusCode()

hasKafkaDeltaInTopic

public boolean hasKafkaDeltaInTopic()
                             throws ExecutionException,
                                    InterruptedException,
                                    TimeoutException

Throws:

ExecutionException

InterruptedException

TimeoutException

setConsumerStatus

public void setConsumerStatus(GSKafkaConsumerStatusEnum newStatus)

getConsumerStatus

public GSKafkaConsumerStatusEnum getConsumerStatus()
                                            throws IOException

Throws:

IOException

getTotalOperation

public int getTotalOperation()
                      throws IOException

Throws:

IOException

delete

public String delete()

getKafkaBoostrap

public String getKafkaBoostrap()

deletePipelineCdcInfo

public void deletePipelineCdcInfo(String pipelineName)
                           throws ExecutionException

Throws:

ExecutionException

clearPipelineTables

public void clearPipelineTables(List<String> typesList)
                         throws ExecutionException

Throws:

ExecutionException

destroy

public void destroy()