Package adams.flow.rest

Class AbstractRESTClientTransformer<I,O>

java.lang.Object

adams.core.logging.LoggingObject

adams.core.logging.CustomLoggingLevelObject

adams.core.option.AbstractOptionHandler

adams.flow.rest.AbstractRESTClientTransformer<I,O>

Type Parameters:

I - the type of input data to handle

O - the type of output data to handle

All Implemented Interfaces:

adams.core.CleanUpHandler, adams.core.Destroyable, adams.core.ErrorProvider, adams.core.GlobalInfoSupporter, adams.core.logging.LoggingLevelHandler, adams.core.logging.LoggingSupporter, adams.core.option.OptionHandler, adams.core.QuickInfoSupporter, adams.core.SizeOfHandler, AlternativeUrlSupporter, RESTClient, RESTClientConsumer<I>, RESTClientProducer<O>, Serializable

Direct Known Subclasses:

EchoClientTransformer

public abstract class AbstractRESTClientTransformer<I,O>
extends adams.core.option.AbstractOptionHandler
implements RESTClientConsumer<I>, RESTClientProducer<O>, adams.core.QuickInfoSupporter, AlternativeUrlSupporter

Ancestor for webservice clients.

Author:

fracpete (fracpete at waikato dot ac dot nz)

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected String	m_AlternativeURL	the URL of the webservice.
protected int	m_ConnectionTimeout	the connection timeout.
protected String	m_LastError	the last error that was generated.
protected adams.flow.core.Actor	m_Owner	the owner.
protected int	m_ReceiveTimeout	the receive timeout.
protected O	m_ResponseData	the response data.
protected HashSet<RESTClientProducerResponseDataListener>	m_ResponseDataListeners	the listeners for reponse data.
protected boolean	m_UseAlternativeURL	whether to use an alternative URL.

Fields inherited from class adams.core.option.AbstractOptionHandler

m_OptionManager

Fields inherited from class adams.core.logging.LoggingObject

m_Logger, m_LoggingIsEnabled, m_LoggingLevel

Constructor Summary

Constructors

Constructor	Description
AbstractRESTClientTransformer()

Method Summary

Modifier and Type	Method	Description
void	addResponseDataListener(RESTClientProducerResponseDataListener l)	Adds the listener for response data being received.
String	alternativeURLTipText()	Returns the tip text for this property.
void	cleanUp()	Cleans up data structures, frees up memory.
String	connectionTimeoutTipText()	Returns the tip text for this property.
void	defineOptions()	Adds options to the internal list of options.
protected abstract void	doQuery()	Performs the actual webservice query.
String	getAlternativeURL()	Returns the alternative URL used for the service.
int	getConnectionTimeout()	Returns the timeout for the connection.
String	getDefaultAlternativeURL()	Returns the default URL for the service.
String	getLastError()	Returns the last error that occurred.
adams.flow.core.Actor	getOwner()	Returns the owning actor.
String	getQuickInfo()	Returns a quick info about the object, which can be displayed in the GUI.
int	getReceiveTimeout()	Returns the timeout for receiving.
O	getResponseData()	Returns the response data, if any.
boolean	getUseAlternativeURL()	Returns whether to use the alternative URL used for the service.
boolean	hasLastError()	Checks whether there was an error with the last call.
boolean	hasResponseData()	Checks whether there is any response data to be collected.
protected void	initialize()	Initializes the members.
protected void	notifyResponseDataListeners()	Notifies all listeners that response data has arrived.
protected void	postQuery()	Hook method after querying the webservice.
protected void	preQuery()	Hook method before querying the webservice.
void	query()	Queries the webservice.
String	receiveTimeoutTipText()	Returns the tip text for this property.
void	removeResponseDataListener(RESTClientProducerResponseDataListener l)	Removes the listener for response data being received.
void	setAlternativeURL(String value)	Sets the alternative URL to use.
void	setConnectionTimeout(int value)	Sets the timeout for connection.
void	setOwner(adams.flow.core.Actor value)	Sets the actor that executes this webservice.
void	setReceiveTimeout(int value)	Sets the timeout for receiving.
void	setResponseData(O value)	Sets the response data.
void	setUseAlternativeURL(boolean value)	Sets whether to use the alternative URL.
String	useAlternativeURLTipText()	Returns the tip text for this property.

Methods inherited from class adams.core.option.AbstractOptionHandler

cleanUpOptions, destroy, finishInit, getDefaultLoggingLevel, getOptionManager, globalInfo, loggingLevelTipText, newOptionManager, reset, setLoggingLevel, toCommandLine, toString

Methods inherited from class adams.core.logging.LoggingObject

configureLogger, getLogger, getLoggingLevel, initializeLogging, isLoggingEnabled, sizeOf

Methods inherited from class java.lang.Object

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

Methods inherited from interface adams.core.Destroyable

destroy

Methods inherited from interface adams.core.logging.LoggingLevelHandler

getLoggingLevel

Methods inherited from interface adams.core.option.OptionHandler

cleanUpOptions, getOptionManager, toCommandLine

Methods inherited from interface adams.flow.rest.RESTClientConsumer

accepts, setRequestData

Methods inherited from interface adams.flow.rest.RESTClientProducer

generates

Field Detail

m_Owner

protected adams.flow.core.Actor m_Owner

the owner.

m_ConnectionTimeout

protected int m_ConnectionTimeout

the connection timeout.

m_ReceiveTimeout

protected int m_ReceiveTimeout

the receive timeout.

m_UseAlternativeURL

protected boolean m_UseAlternativeURL

whether to use an alternative URL.

m_AlternativeURL

protected String m_AlternativeURL

the URL of the webservice.

m_ResponseData

protected transient O m_ResponseData

the response data.

m_ResponseDataListeners

protected HashSet<RESTClientProducerResponseDataListener> m_ResponseDataListeners

the listeners for reponse data.

m_LastError

protected String m_LastError

the last error that was generated.

Constructor Detail

AbstractRESTClientTransformer

public AbstractRESTClientTransformer()

Method Detail

defineOptions

public void defineOptions()

Adds options to the internal list of options.

Specified by:

defineOptions in interface adams.core.option.OptionHandler

Overrides:

defineOptions in class adams.core.option.AbstractOptionHandler

initialize

protected void initialize()

Initializes the members.

Overrides:

initialize in class adams.core.option.AbstractOptionHandler

setConnectionTimeout

public void setConnectionTimeout(int value)

Sets the timeout for connection.

Specified by:

setConnectionTimeout in interface RESTClient

Parameters:

value - the timeout in msec, 0 is infinite

getConnectionTimeout

public int getConnectionTimeout()

Returns the timeout for the connection.

Specified by:

getConnectionTimeout in interface RESTClient

Returns:

the timeout in msec, 0 is infinite

connectionTimeoutTipText

public String connectionTimeoutTipText()

Returns the tip text for this property.

Returns:

tip text for this property suitable for displaying in the GUI or for listing the options.

setReceiveTimeout

public void setReceiveTimeout(int value)

Sets the timeout for receiving.

Specified by:

setReceiveTimeout in interface RESTClient

Parameters:

value - the timeout in msec, 0 is infinite

getReceiveTimeout

public int getReceiveTimeout()

Returns the timeout for receiving.

Specified by:

getReceiveTimeout in interface RESTClient

Returns:

the timeout in msec, 0 is infinite

receiveTimeoutTipText

public String receiveTimeoutTipText()

Returns the tip text for this property.

Returns:

tip text for this property suitable for displaying in the GUI or for listing the options.

setUseAlternativeURL

public void setUseAlternativeURL(boolean value)

Sets whether to use the alternative URL.

Specified by:

setUseAlternativeURL in interface AlternativeUrlSupporter

Parameters:

value - whether to use the alternative URL

getUseAlternativeURL

public boolean getUseAlternativeURL()

Returns whether to use the alternative URL used for the service.

Specified by:

getUseAlternativeURL in interface AlternativeUrlSupporter

Returns:

true if to use alternative URL

useAlternativeURLTipText

public String useAlternativeURLTipText()

Returns the tip text for this property.

Specified by:

useAlternativeURLTipText in interface AlternativeUrlSupporter

Returns:

tip text for this property suitable for displaying in the GUI or for listing the options.

getDefaultAlternativeURL

public String getDefaultAlternativeURL()

Returns the default URL for the service.

Specified by:

getDefaultAlternativeURL in interface AlternativeUrlSupporter

Returns:

the URL

setAlternativeURL

public void setAlternativeURL(String value)

Sets the alternative URL to use.

Specified by:

setAlternativeURL in interface AlternativeUrlSupporter

Parameters:

value - the URL to use

getAlternativeURL

public String getAlternativeURL()

Returns the alternative URL used for the service.

Specified by:

getAlternativeURL in interface AlternativeUrlSupporter

Returns:

the URL

alternativeURLTipText

public String alternativeURLTipText()

Returns the tip text for this property.

Specified by:

alternativeURLTipText in interface AlternativeUrlSupporter

Returns:

tip text for this property suitable for displaying in the GUI or for listing the options.

getQuickInfo

public String getQuickInfo()

Returns a quick info about the object, which can be displayed in the GUI.

Specified by:

getQuickInfo in interface adams.core.QuickInfoSupporter

Returns:

null if no info available, otherwise short string

setOwner

public void setOwner(adams.flow.core.Actor value)

Sets the actor that executes this webservice.

Specified by:

setOwner in interface RESTClient

Parameters:

value - the owner

getOwner

public adams.flow.core.Actor getOwner()

Returns the owning actor.

Specified by:

getOwner in interface RESTClient

Returns:

the owner

hasLastError

public boolean hasLastError()

Checks whether there was an error with the last call.

Specified by:

hasLastError in interface adams.core.ErrorProvider

Returns:

true if there was an error

See Also:

getLastError()

getLastError

public String getLastError()

Returns the last error that occurred.

Specified by:

getLastError in interface adams.core.ErrorProvider

Returns:

the last error, null if none occurred

addResponseDataListener

public void addResponseDataListener(RESTClientProducerResponseDataListener l)

Adds the listener for response data being received.

Specified by:

addResponseDataListener in interface RESTClientProducer<I>

Parameters:

l - the listener to add

removeResponseDataListener

public void removeResponseDataListener(RESTClientProducerResponseDataListener l)

Removes the listener for response data being received.

Specified by:

removeResponseDataListener in interface RESTClientProducer<I>

Parameters:

l - the listener to remove

notifyResponseDataListeners

protected void notifyResponseDataListeners()

Notifies all listeners that response data has arrived.

hasResponseData

public boolean hasResponseData()

Checks whether there is any response data to be collected.

Specified by:

hasResponseData in interface RESTClientProducer<I>

Returns:

true if data can be collected

See Also:

getResponseData()

setResponseData

public void setResponseData(O value)

Sets the response data.

Specified by:

setResponseData in interface RESTClientProducer<I>

Parameters:

value - the response data

getResponseData

public O getResponseData()

Returns the response data, if any.

Specified by:

getResponseData in interface RESTClientProducer<I>

Returns:

the response data

preQuery

protected void preQuery()
                 throws Exception

Hook method before querying the webservice.

Default implementation ensures that an owner is set.

Throws:

Exception - if it fails for some reason

doQuery

protected abstract void doQuery()
                         throws Exception

Performs the actual webservice query.

Throws:

Exception - if accessing webservice fails for some reason

postQuery

protected void postQuery()
                  throws Exception

Hook method after querying the webservice.

Default implementation does nothing.

Throws:

Exception - if it fails for some reason

query

public void query()
           throws Exception

Queries the webservice.

Specified by:

query in interface RESTClient

Throws:

Exception - if accessing webservice fails for some reason

cleanUp

public void cleanUp()

Cleans up data structures, frees up memory.
Default implementation does nothing.

Specified by:

cleanUp in interface adams.core.CleanUpHandler