org.thales.punch.kafka.application

Class ApplicationExitControllerImpl

java.lang.Object

org.thales.punch.kafka.application.ApplicationExitControllerImpl

All Implemented Interfaces:

AutoCloseable, IRecordHandler<String,byte[]>, org.thales.punch.platform.api.IApplicationExitController

public class ApplicationExitControllerImpl
extends Object
implements org.thales.punch.platform.api.IApplicationExitController, IRecordHandler<String,byte[]>

The exit controller watch a kafka topic and report to you these application you need to monitor to be told upon their wish to exit.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
ApplicationExitControllerImpl(String entityUUID, org.thales.punch.libraries.metrics.api.IMetricContext mc) Ctor.

Method Summary

Modifier and Type	Method and Description
void	close()
List<org.thales.punch.platform.api.IApplication>	getTerminatedApplications(List<org.thales.punch.platform.api.IApplication> list, Duration timeout)
void	onReceive(IPartition partition, org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record) Be notified upon the arrival of a record.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.kafka.api.IRecordHandler

onPartitionAssigned, onPartitionRevoked, onTick

Constructor Detail

ApplicationExitControllerImpl

public ApplicationExitControllerImpl(String entityUUID,
                                     org.thales.punch.libraries.metrics.api.IMetricContext mc)
                              throws org.thales.punch.exceptions.ConfigurationException

Ctor.

Parameters:

entityUUID - the unique id of your entity; only the application belonging to that entity will be reported.

mc - a metric context

Throws:

org.thales.punch.exceptions.ConfigurationException

Method Detail

getTerminatedApplications

public List<org.thales.punch.platform.api.IApplication> getTerminatedApplications(List<org.thales.punch.platform.api.IApplication> list,
                                                                                  Duration timeout)

Specified by:

getTerminatedApplications in interface org.thales.punch.platform.api.IApplicationExitController

onReceive

public void onReceive(IPartition partition,
                      org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

Description copied from interface: IRecordHandler

Be notified upon the arrival of a record.

Specified by:

onReceive in interface IRecordHandler<String,byte[]>

Parameters:

partition - the receiving partition. Use it to acknowledge or fail your records in the way you need.

record - the record

close

public void close()

Specified by:

close in interface AutoCloseable