ddf.catalog.resource.download

Class ResourceRetrievalMonitor

java.lang.Object

java.util.TimerTask

ddf.catalog.resource.download.ResourceRetrievalMonitor

All Implemented Interfaces:

Runnable

public class ResourceRetrievalMonitor
extends TimerTask

Monitors the @ReliableResourceCallable, detecting if no bytes have been read from the resource's @InputStream for the monitor's period. If this is detected, then this monitor is canceled, the @ReliableResourceCallable's interrupt flag is set, and the @Future that started it is canceled.

Constructor Summary

Constructors

Constructor and Description
ResourceRetrievalMonitor(Future<?> future, ReliableResourceCallable reliableResourceCallable, long monitorPeriod, DownloadsStatusEventPublisher eventPublisher, ResourceResponse resourceResponse, Metacard metacard, String downloadIdentifier)

Method Summary

Modifier and Type	Method and Description
long	getBytesRead() Returns the number of bytes read from the resource's @InputStream thus far.
void	run()

Methods inherited from class java.util.TimerTask

cancel, scheduledExecutionTime

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceRetrievalMonitor

public ResourceRetrievalMonitor(Future<?> future,
                                ReliableResourceCallable reliableResourceCallable,
                                long monitorPeriod,
                                DownloadsStatusEventPublisher eventPublisher,
                                ResourceResponse resourceResponse,
                                Metacard metacard,
                                String downloadIdentifier)

Parameters:

future - the @Future that started the @ReliableResourceCallable doing the resource download

reliableResourceCallable - the @Callable to interrupt if no bytes read in specified period

monitorPeriod - the frequency (in ms) this monitor should check for bytes read

eventPublisher - reference to the publisher of status events as the download progresses

resourceResponse - the resource response of the request

metacard - the @Metacard associated with the resource being downloaded

Method Detail

getBytesRead

public long getBytesRead()

Returns the number of bytes read from the resource's @InputStream thus far.

Returns:

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class TimerTask