org.gcube.data.spd.plugin.fwk.writers.rswrapper

Class AbstractLocalWrapper<T>

java.lang.Object

org.gcube.data.spd.plugin.fwk.writers.rswrapper.AbstractWrapper<T>

org.gcube.data.spd.plugin.fwk.writers.rswrapper.AbstractLocalWrapper<T>

Direct Known Subclasses:

LocalWrapper

public abstract class AbstractLocalWrapper<T>
extends AbstractWrapper<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closed

Fields inherited from class org.gcube.data.spd.plugin.fwk.writers.rswrapper.AbstractWrapper

links

Constructor Summary

Constructors

Constructor and Description
AbstractLocalWrapper()
AbstractLocalWrapper(int queueSize)

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	disposeBuffer()
String	getLocator()
abstract BlockingQueue<T>	getQueue()
boolean	isClosed()

Methods inherited from class org.gcube.data.spd.plugin.fwk.writers.rswrapper.AbstractWrapper

add, add, close, register, unregister

Methods inherited from class java.lang.Object

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

Field Detail

closed

protected boolean closed

Constructor Detail

AbstractLocalWrapper

public AbstractLocalWrapper()

AbstractLocalWrapper

public AbstractLocalWrapper(int queueSize)

Method Detail

getQueue

public abstract BlockingQueue<T> getQueue()

getLocator

public String getLocator()
                  throws Exception

Specified by:

getLocator in class AbstractWrapper<T>

Throws:

Exception

isClosed

public boolean isClosed()

Specified by:

isClosed in class AbstractWrapper<T>

disposeBuffer

public abstract void disposeBuffer()