org.thales.punch.libraries.punchlang.resource

Class RemoteResourceHandler

java.lang.Object

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

org.thales.punch.libraries.punchlang.resource.RemoteResourceHandler

All Implemented Interfaces:

Serializable, Runnable, Supplier<Tuple>

public class RemoteResourceHandler
extends AbstractRemoteResourceHandler

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/interfaces inherited from class org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

AbstractRemoteResourceHandler.AtomicTupleReference

Field Summary

Fields inherited from class org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

atomicTupleReference, builder, logger, requiredResource, resourceUuid

Constructor Summary

Constructors

Constructor and Description
RemoteResourceHandler(String resourceUuid, String url, IResourceBuilder builder, String cron, boolean requiredResource, boolean silent, org.thales.punch.libraries.metrics.api.IMetricContext mc) Ctor

Method Summary

Modifier and Type	Method and Description
protected static InputStreamReader	getFileStream(String path)
protected static Tuple	getResourceFromFile(String resourceUrl, IResourceBuilder builder)
protected static Tuple	getResourceFromHttp(String resourceUrl, IResourceBuilder builder)
void	reload()
static Tuple	testGetResourceFromFile(String resourceUrl, IResourceBuilder builder) Test method to fetch files.

Methods inherited from class org.thales.punch.libraries.punchlang.resource.AbstractRemoteResourceHandler

clear, get, loadingFailures, loadingSuccess, run, start, startLoading, stop, stopLoading

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteResourceHandler

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

Ctor

Parameters:

resourceUrl - 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

getResourceFromHttp

protected static Tuple getResourceFromHttp(String resourceUrl,
                                           IResourceBuilder builder)
                                    throws org.apache.http.client.ClientProtocolException,
                                           IOException

Throws:

org.apache.http.client.ClientProtocolException

IOException

getFileStream

protected static InputStreamReader getFileStream(String path)
                                          throws IOException

Throws:

IOException

getResourceFromFile

protected static Tuple getResourceFromFile(String resourceUrl,
                                           IResourceBuilder builder)
                                    throws IOException

Parameters:

resourceUrl - the url of a resource file.

builder - the resource builder

Returns:

the resulting resource as provided by the underlying builder

Throws:

IOException

testGetResourceFromFile

public static Tuple testGetResourceFromFile(String resourceUrl,
                                            IResourceBuilder builder)
                                     throws IOException

Test method to fetch files.

Parameters:

resourceUrl -

builder -

Returns:

Throws:

IOException

reload

public void reload()
            throws IOException

Specified by:

reload in class AbstractRemoteResourceHandler

Throws:

IOException