org.eclipse.cosmos.dc.common.api.impl
Class AbstractSource

java.lang.Object
  org.eclipse.cosmos.dc.common.api.impl.AbstractSource

All Implemented Interfaces:

IDataSourceService, IWireSource

Direct Known Subclasses:

CBESource, JMXMetricSource, JMXPollingSource, WefSource

public abstract class AbstractSource
extends java.lang.Object
implements IDataSourceService, IWireSource

Field Summary

protected IDataSourceService	_proxy
protected java.util.ArrayList<IWireTarget>	targetList

Fields inherited from interface org.eclipse.cosmos.dc.common.api.IDataSourceService

DATA_SOURCE_QNAME, FACTORY_QNAME, SOURCE_QNAME

Constructor Summary

AbstractSource(ContributionManager manager)

Method Summary

abstract boolean	acceptWireTarget(IWireTarget target)
void	addWireTarget(IWireTarget target)
abstract boolean	cancel()
abstract boolean	connect()
abstract boolean	disconnect()
void	dispatch(java.lang.Object obj)
java.lang.reflect.Method	getWireMethod()
IWireTarget[]	getWireTargets()
abstract boolean	pause()
abstract boolean	resume()
abstract boolean	run()
void	setWireMethod(java.lang.reflect.Method wireMethod)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.cosmos.dc.common.api.IDataSourceService

getDataSource, getOutputTypes

Field Detail

_proxy

protected IDataSourceService _proxy

targetList

protected java.util.ArrayList<IWireTarget> targetList

Constructor Detail

AbstractSource

public AbstractSource(ContributionManager manager)

Method Detail

acceptWireTarget

public abstract boolean acceptWireTarget(IWireTarget target)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

addWireTarget

public void addWireTarget(IWireTarget target)
                   throws java.lang.Exception

Specified by:

addWireTarget in interface IWireSource

Throws:

java.lang.Exception

getWireTargets

public IWireTarget[] getWireTargets()

Specified by:

getWireTargets in interface IWireSource

setWireMethod

public void setWireMethod(java.lang.reflect.Method wireMethod)

getWireMethod

public java.lang.reflect.Method getWireMethod()

dispatch

public void dispatch(java.lang.Object obj)

connect

public abstract boolean connect()
                         throws java.lang.Exception

Specified by:

connect in interface IDataSourceService

Throws:

java.lang.Exception

run

public abstract boolean run()
                     throws java.lang.Exception

Specified by:

run in interface IDataSourceService

Throws:

java.lang.Exception

disconnect

public abstract boolean disconnect()
                            throws java.lang.Exception

Specified by:

disconnect in interface IDataSourceService

Throws:

java.lang.Exception

cancel

public abstract boolean cancel()
                        throws java.lang.Exception

Specified by:

cancel in interface IDataSourceService

Throws:

java.lang.Exception

pause

public abstract boolean pause()
                       throws java.lang.Exception

Specified by:

pause in interface IDataSourceService

Throws:

java.lang.Exception

resume

public abstract boolean resume()
                        throws java.lang.Exception

Specified by:

resume in interface IDataSourceService

Throws:

java.lang.Exception