Modifier and Type | Method and Description |
---|---|
boolean |
EventAdminSender.send(Data data)
Send the Data object
|
Modifier and Type | Field and Description |
---|---|
protected List<Data> |
AbstractAsyncIOAdapter.currentData |
Modifier and Type | Method and Description |
---|---|
protected Data |
AbstractIOAdapter.callAndWait(Data data)
Send the data to the first mediator and wait for the reponse.
|
Data |
AbstractAsyncIOAdapter.dispatchData(Data data) |
Data |
AbstractIOAdapter.dispatchData(Data data) |
Data |
AbstractIOAdapter.invokeChain(Data data)
Invoke a Chain with the data as parammeter.
|
Data |
ICollector.notifyDataArrival(Data data)
Notify to the Scheduler when data has arrive.
|
Data |
AbstractCollector.notifyDataArrival(Data data)
Notify to the Scheduler when data has arrive.
|
Modifier and Type | Method and Description |
---|---|
List<Data> |
AbstractAsyncIOAdapter.getData() |
Modifier and Type | Method and Description |
---|---|
protected Data |
AbstractIOAdapter.callAndWait(Data data)
Send the data to the first mediator and wait for the reponse.
|
abstract void |
AbstractDispatcher.dispatch(Data data) |
void |
IDispatcher.dispatch(Data dataSet) |
Data |
AbstractAsyncIOAdapter.dispatchData(Data data) |
Data |
AbstractIOAdapter.dispatchData(Data data) |
protected String |
AbstractIOAdapter.generateKey(Data data)
Generate a key to track response.
|
String |
AbstractCorrelationScheduler.getCorrelationKey(Data data) |
Data |
AbstractIOAdapter.invokeChain(Data data)
Invoke a Chain with the data as parammeter.
|
void |
IScheduler.notifyData(Data data) |
abstract void |
AbstractScheduler.notifyData(Data data) |
void |
AbstractCorrelationScheduler.notifyData(Data data) |
Data |
ICollector.notifyDataArrival(Data data)
Notify to the Scheduler when data has arrive.
|
Data |
AbstractCollector.notifyDataArrival(Data data)
Notify to the Scheduler when data has arrive.
|
void |
AbstractAsyncIOAdapter.receiveData(Data data) |
void |
AbstractIOAdapter.receiveData(Data data) |
boolean |
ISender.send(Data data) |
void |
AbstractDispatcher.send(String portname,
Data data) |
void |
IDispatcher.send(String senderName,
Data data) |
void |
AbstractDispatcher.send(String portname,
Properties properties,
Data data) |
void |
IDispatcher.send(String senderName,
Properties properties,
Data data) |
abstract List |
AbstractSplitter.split(Data dataToSplit) |
Modifier and Type | Method and Description |
---|---|
Data |
XsltTransformerProcessor.process(Data data) |
Data |
PrefixEnricherProcessor.process(Data data) |
Data |
SufixEnricherProcessor.process(Data data) |
Data |
SimpleEnricherProcessor.process(Data data) |
Data |
LocalSemanticTranslatorProcessor.process(Data dataSet)
Will translate words on the content of a data.
|
Modifier and Type | Method and Description |
---|---|
protected List<Data> |
RandomNumberCollector.pullData() |
Modifier and Type | Method and Description |
---|---|
void |
ContentBasedDispatcher.dispatch(Data data)
Method to call when processing is finished
and used to send data to destinations.
|
void |
DescriptorBasedDispatcher.dispatch(Data data)
Method to call when processing is finished
and used to send data to destinations.
|
void |
MulticastDispatcher.dispatch(Data data) |
void |
ImmediateScheduler.notifyData(Data data) |
void |
PeriodicScheduler.notifyData(Data data)
Method called by collectors when they collect new Data.
|
Data |
XsltTransformerProcessor.process(Data data) |
Data |
PrefixEnricherProcessor.process(Data data) |
Data |
SufixEnricherProcessor.process(Data data) |
Data |
SimpleEnricherProcessor.process(Data data) |
Data |
LocalSemanticTranslatorProcessor.process(Data dataSet)
Will translate words on the content of a data.
|
void |
IDirectCollector.receive(Data data)
Method called when direct sender send data.
|
void |
DirectCollector.receive(Data data)
This method is called by the direct sender.
|
boolean |
ConsoleSender.send(Data data) |
boolean |
DirectSender.send(Data data)
It will send the given data to the collector
associated to this sender.
|
List |
XpathSplitter.split(Data receiveData)
Split one data.
|
List |
SplitterProcessor.split(Data dataToSplit) |
Modifier and Type | Method and Description |
---|---|
static Data |
DataEnrichment.addCorrelationInfo(Data data,
int size,
int number,
String id)
Add split info to be used in agregator.
|
static Data |
DataEnrichment.addMetadataInfo(Data data,
Dictionary newmetadata)
Add Metadata information to the given Data.
|
static Data |
XsltTransformator.dataTransformFromPathFile(Data data,
String xsltPathFile)
Transforms the content of Data using XSLT.
|
static Data |
XsltTransformator.dataTransformFromURL(Data data,
String xsltUrl)
Transforms the content of Data using XSLT.
|
Modifier and Type | Method and Description |
---|---|
static Data |
DataEnrichment.addCorrelationInfo(Data data,
int size,
int number,
String id)
Add split info to be used in agregator.
|
static Data |
DataEnrichment.addMetadataInfo(Data data,
Dictionary newmetadata)
Add Metadata information to the given Data.
|
static Data |
XsltTransformator.dataTransformFromPathFile(Data data,
String xsltPathFile)
Transforms the content of Data using XSLT.
|
static Data |
XsltTransformator.dataTransformFromURL(Data data,
String xsltUrl)
Transforms the content of Data using XSLT.
|
boolean |
CiliaExpression.evaluateBooleanExpression(String expr,
Data data)
Evaluate and expression.
|
boolean |
ExpressionLDAP.evaluateBooleanExpression(String expression,
Data data)
Evaluate the given expression and see if it match with the given data.
|
boolean |
ExpressionXPATH.evaluateBooleanExpression(String expr,
Data data)
Evaluate the given expression and see if it match with the given data.
|
List |
CiliaExpression.evaluateExpression(String expre,
Data data)
Evaluate an expression.
|
List |
ExpressionLDAP.evaluateExpression(String expre,
Data data)
Evaluate the given expression and see if it match with the given data.
|
List |
ExpressionXPATH.evaluateExpression(String expression,
Data data) |
static int |
DataEnrichment.getCorrelatedTotal(Data data)
When Data is enrichment with SplittInfo, this method
will return the amount of pices the Data was splitted .
|
String |
CiliaExpression.resolveVariables(String expr,
Data data)
Used to remplace variables in the given expression.
|
String |
ExpressionLDAP.resolveVariables(String expression,
Data data)
TODO: move the next code to another class.
|
String |
ExpressionXPATH.resolveVariables(String expr,
Data data)
TODO: move the next code to another class.
|
static List |
XmlSplitter.split(Data data,
String expression)
Split a given org.ow2.chameleon.cilia.Data using a given XPath expression.
|
static List |
XmlSplitter.split(Data data,
String expression,
boolean addSplitInfo) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMonitor.onCollect(Data data) |
void |
IMonitor.onCollect(Data data) |
Modifier and Type | Method and Description |
---|---|
void |
MonitorHandlerStateVar.onCollect(Data data) |
void |
MonitorHandlerStateVar.onProcessError(Data data,
Exception ex) |
Modifier and Type | Method and Description |
---|---|
boolean |
JMSSender.send(Data data) |
Modifier and Type | Method and Description |
---|---|
boolean |
JMSSender.send(Data data) |
Modifier and Type | Class and Description |
---|---|
class |
SerializedData |
Modifier and Type | Method and Description |
---|---|
Data |
SerializedData.deserializeContent(org.osgi.framework.BundleContext bcontext) |
Constructor and Description |
---|
SerializedData(Data odata) |
Modifier and Type | Method and Description |
---|---|
boolean |
TCPSender.send(Data data) |
Copyright © 2012-2013 Adele Team | LIG. All Rights Reserved.