|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
A StreamingDataSourceConnector is a connection to a data source that generates streaming data. For example, this could be a financial market data feed handler.
Inner classes inherited from class com.bea.wlrt.ede.Schedulable |
Schedulable.Parameter |
Method Summary | |
void |
closeConnection(int sessionId,
Map args)
Closes the adapter connection with the data stream. |
String |
getName()
Gets the Adapter Descriptive name |
Map |
getProperties()
Provides the map of all the adapter properties for a particular data stream providers. |
String |
getProperty(String propertyName)
This provides the value for a given property name. |
boolean |
isConnected()
Return true if the adapter is currently connected to the data stream provider. |
int |
openSession(Map args)
This methods establishes the link, between the adapter and the data stream provider. |
void |
setProperties(Map propertySet)
This method provides help to setup the all the properties for a adapter. |
void |
setProperty(String propertyName,
String propertyValue)
This method helps to set value for a given property. |
void |
subscribe(int sessionId,
List subscriptions)
List of subscriptions that the adapter is interested in listening from the data stream. e.g. |
void |
subscribe(int sessionId,
List subscriptions,
StreamingEventListener subscriber)
List of subscriptions that the adapter is interested in listening from the data stream. e.g. |
void |
unsubscribe(int sessionId,
List subscriptions)
Unsubscribe the subscriptions |
Methods inherited from interface com.bea.wlrt.ede.Adapter |
getEventGenerator |
Methods inherited from interface com.bea.wlrt.ede.Stage |
destroy,
getId,
getResourceManager,
getStatsManager |
Methods inherited from interface com.bea.wlrt.ede.Schedulable |
addParameter,
getParameters,
removeParameter |
Methods inherited from interface com.bea.wlrt.ede.StreamingEventSource |
addStreamingEventListener,
getStreamingEventListeners,
removeStreamingEventListener |
Methods inherited from interface com.bea.wlrt.ede.StreamingEventListener |
onEvent |
Methods inherited from interface java.lang.Iterable |
iterator |
Method Detail |
public String getName()
public int openSession(Map args) throws InstantiationException
public Map getProperties()
public void setProperties(Map propertySet)
public String getProperty(String propertyName) throws IllegalArgumentException
public void setProperty(String propertyName, String propertyValue) throws IllegalArgumentException
public boolean isConnected()
public void subscribe(int sessionId, List subscriptions) throws SubscriptionException, IllegalArgumentException
public void subscribe(int sessionId, List subscriptions, StreamingEventListener subscriber) throws SubscriptionException, IllegalArgumentException
public void unsubscribe(int sessionId, List subscriptions) throws SubscriptionException, IllegalArgumentException
public void closeConnection(int sessionId, Map args) throws IllegalArgumentException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |