org.thales.punch.libraries.punchlang.resource

Class AbstractRemoteResourceHandler

java.lang.Object

org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

All Implemented Interfaces:

Serializable, Runnable, Supplier<Tuple>

Direct Known Subclasses:

RemoteResourceHandler, S3RemoteResourceHandler

public abstract class AbstractRemoteResourceHandler
extends Object
implements Serializable, Runnable, Supplier<Tuple>

This abstract class responsibility is to take care of the thread that will periodically check and fire the reloading of a remote resource file.

It is used to implement atomic or incremental variant to periodically reload remote resources.

Author:

dimi

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractRemoteResourceHandler.AtomicTupleReference The result fetched by caller.

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicReference<AbstractRemoteResourceHandler.AtomicTupleReference>	atomicTupleReference The result that holds the fetched resource
protected IResourceBuilder	builder
protected static org.apache.logging.log4j.Logger	logger
protected boolean	requiredResource If true, the get resource must be loaded first before any first retrieval.
protected String	resourceUuid

Constructor Summary

Constructors

Constructor and Description
AbstractRemoteResourceHandler(String resourceUuid, IResourceBuilder builder, String cron, boolean requiredResource, boolean silent, org.thales.punch.libraries.metrics.api.IMetricContext mc) Ctor using a plain HTTP HTTPS or file URL.

Method Summary

Modifier and Type	Method and Description
static void	clear() Test method to clear the resources after some tests
Tuple	get()
protected void	loadingFailures()
protected void	loadingSuccess()
abstract void	reload()
void	run()
Supplier<Tuple>	start()
protected com.codahale.metrics.Timer.Context	startLoading()
void	stop()
protected static void	stopLoading(com.codahale.metrics.Timer.Context c)

Methods inherited from class java.lang.Object

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

Field Detail

builder

protected transient IResourceBuilder builder

logger

protected static final org.apache.logging.log4j.Logger logger

resourceUuid

protected String resourceUuid

requiredResource

protected final boolean requiredResource

If true, the get resource must be loaded first before any first retrieval.

atomicTupleReference

protected final AtomicReference<AbstractRemoteResourceHandler.AtomicTupleReference> atomicTupleReference

The result that holds the fetched resource

Constructor Detail

AbstractRemoteResourceHandler

public AbstractRemoteResourceHandler(String resourceUuid,
                                     IResourceBuilder builder,
                                     String cron,
                                     boolean requiredResource,
                                     boolean silent,
                                     org.thales.punch.libraries.metrics.api.IMetricContext mc)

Ctor using a plain HTTP HTTPS or file URL.

Parameters:

resourceUuid - the remote or local resource URL

cron - the CRON expression. If null no thread is launched.

builder - the resource builder in charge of transforming the loaded resources

requiredResource - true to make it mandatory to load the resource first

mc - the metrics context

Method Detail

startLoading

protected com.codahale.metrics.Timer.Context startLoading()

stopLoading

protected static void stopLoading(com.codahale.metrics.Timer.Context c)

loadingFailures

protected void loadingFailures()

loadingSuccess

protected void loadingSuccess()

run

public void run()

Specified by:

run in interface Runnable

start

public Supplier<Tuple> start()

stop

public void stop()

clear

public static void clear()

Test method to clear the resources after some tests

reload

public abstract void reload()
                     throws IOException

Throws:

IOException

get

public Tuple get()

Specified by:

get in interface Supplier<Tuple>