Package adams.flow.webservice

Class AbstractWebServiceClientSink<I>

java.lang.Object

adams.core.logging.LoggingObject

adams.core.logging.CustomLoggingLevelObject

adams.core.option.AbstractOptionHandler

adams.flow.webservice.AbstractWebServiceClientSink<I>

Type Parameters:

I - the type of input data to handle

All Implemented Interfaces:

adams.core.AdditionalInformationHandler, 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, WebServiceClient, WebServiceClientConsumer<I>, WsdlUrlProvider, Serializable

Direct Known Subclasses:

AbstractWebServiceClientSinkWithCallableTransformer, UpdateCustomer, Upload, Upload

public abstract class AbstractWebServiceClientSink<I>
extends adams.core.option.AbstractOptionHandler
implements WebServiceClientConsumer<I>, adams.core.QuickInfoSupporter, WsdlUrlProvider, AlternativeUrlSupporter

Ancestor for webservice clients.

Version:

$Revision$

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 AbstractOutInterceptorGenerator	m_OutInterceptor	the interceptor generator for outgoing messages.
protected adams.flow.core.Actor	m_Owner	the owner.
protected int	m_ReceiveTimeout	the receive timeout.
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
AbstractWebServiceClientSink()

Method Summary

Modifier and Type	Method	Description
String	alternativeURLTipText()	Returns the tip text for this property.
void	cleanUp()	Cleans up the client.
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	getAdditionalInformation()	Returns the additional information.
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.
protected AbstractOutInterceptorGenerator	getDefaultOutInterceptor()	Returns the default interceptor for outgoing messages.
String	getLastError()	Returns the last error that occurred.
AbstractOutInterceptorGenerator	getOutInterceptor()	Returns the interceptor for outgoing messages.
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.
boolean	getUseAlternativeURL()	Returns whether to use the alternative URL used for the service.
abstract URL	getWsdlLocation()	Returns the WSDL location.
boolean	hasLastError()	Checks whether there was an error with the last call.
String	outInterceptorTipText()	Returns the tip text for this property.
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	setAlternativeURL(String value)	Sets the alternative URL to use.
void	setConnectionTimeout(int value)	Sets the timeout for connection.
void	setOutInterceptor(AbstractOutInterceptorGenerator value)	Sets the interceptor for outgoing messages.
void	setOwner(adams.flow.core.Actor value)	Sets the actor that executes this webservice.
void	setReceiveTimeout(int value)	Sets the timeout for receiving.
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, initialize, 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.webservice.WebServiceClientConsumer

accepts, setRequestData

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_OutInterceptor

protected AbstractOutInterceptorGenerator m_OutInterceptor

the interceptor generator for outgoing messages.

m_LastError

protected String m_LastError

the last error that was generated.

Constructor Detail

AbstractWebServiceClientSink

public AbstractWebServiceClientSink()

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

setConnectionTimeout

public void setConnectionTimeout(int value)

Sets the timeout for connection.

Specified by:

setConnectionTimeout in interface WebServiceClient

Parameters:

value - the timeout in msec, 0 is infinite

getConnectionTimeout

public int getConnectionTimeout()

Returns the timeout for the connection.

Specified by:

getConnectionTimeout in interface WebServiceClient

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 WebServiceClient

Parameters:

value - the timeout in msec, 0 is infinite

getReceiveTimeout

public int getReceiveTimeout()

Returns the timeout for receiving.

Specified by:

getReceiveTimeout in interface WebServiceClient

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.

getDefaultOutInterceptor

protected AbstractOutInterceptorGenerator getDefaultOutInterceptor()

Returns the default interceptor for outgoing messages.

Returns:

the interceptor

setOutInterceptor

public void setOutInterceptor(AbstractOutInterceptorGenerator value)

Sets the interceptor for outgoing messages.

Specified by:

setOutInterceptor in interface WebServiceClientConsumer<I>

Parameters:

value - the interceptor

getOutInterceptor

public AbstractOutInterceptorGenerator getOutInterceptor()

Returns the interceptor for outgoing messages.

Specified by:

getOutInterceptor in interface WebServiceClientConsumer<I>

Returns:

the interceptor

outInterceptorTipText

public String outInterceptorTipText()

Returns the tip text for this property.

Returns:

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

getAdditionalInformation

public String getAdditionalInformation()

Returns the additional information.

Specified by:

getAdditionalInformation in interface adams.core.AdditionalInformationHandler

Returns:

the additional information, null or 0-length string for no information

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 WebServiceClient

Parameters:

value - the owner

getOwner

public adams.flow.core.Actor getOwner()

Returns the owning actor.

Specified by:

getOwner in interface WebServiceClient

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

getWsdlLocation

public abstract URL getWsdlLocation()

Returns the WSDL location.

Specified by:

getWsdlLocation in interface WsdlUrlProvider

Returns:

the location

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 WebServiceClient

Throws:

Exception - if accessing webservice fails for some reason

cleanUp

public void cleanUp()

Cleans up the client.

Specified by:

cleanUp in interface adams.core.CleanUpHandler