public class KEngineImpl extends TopologyImpl implements ApplicationRuntime
ciliaContainer
CHAIN_STATE_IDLE, CHAIN_STATE_STARTED, CHAIN_STATE_STOPPED
Constructor and Description |
---|
KEngineImpl(org.osgi.framework.BundleContext bc,
CiliaContainer cc,
Eventing evtManager) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(String ldapFilter,
ChainCallback listener)
Adds a listener
|
void |
addListener(String ldapFilter,
NodeCallback listener) |
void |
addListener(String ldapfilter,
ThresholdsCallback listener)
inserts a listener
|
void |
addListener(String ldapfilter,
VariableCallback listener) |
boolean |
copyData(Node from,
Node to)
copy messages ( regular and stored)
|
Map |
getBufferedData(Node node)
Get a copy of the map buffered for the fiven mediator
|
int |
getChainState(String chainId)
gives the current chain state
|
Dictionary |
getProperties(Node node)
Return all properties for a node
|
Object |
getProperty(Node node,
String key)
Return a specified property
|
Date |
lastCommand(String chainId)
Return date and time last command [start,stop] level chain
|
Thresholds |
nodeMonitoring(Node node)
fast access using the node reference
|
Thresholds[] |
nodeMonitoring(String ldapFilter) |
RawData |
nodeRawData(Node node)
fast access using the node reference
|
RawData[] |
nodeRawData(String ldapFilter) |
SetUp |
nodeSetup(Node node)
fast access using the node reference
|
SetUp[] |
nodeSetup(String ldapFilter) |
void |
removeListener(ChainCallback listener)
Removes a listener
|
void |
removeListener(NodeCallback listener) |
void |
removeListener(ThresholdsCallback listener)
Removes a threshold listener
|
void |
removeListener(VariableCallback listener)
Removes a Measure listener
|
void |
start() |
void |
startChain(String chainId)
start a chain
|
void |
stop() |
void |
stopChain(String chainId)
stop a chain
|
connectedTo, connectedTo, connectedTo, connectedTo, endpointIn, endpointIn, endpointOut, endpointOut, findNodeByFilter, findNodeByFilter, getChain, getChainId, getModel, getNextNodes, nodeByType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChainId
connectedTo, connectedTo, connectedTo, connectedTo, endpointIn, endpointIn, endpointOut, endpointOut, findNodeByFilter, findNodeByFilter, nodeByType
getChain, getModel
public KEngineImpl(org.osgi.framework.BundleContext bc, CiliaContainer cc, Eventing evtManager)
public void start()
public void stop()
public Dictionary getProperties(Node node) throws CiliaIllegalStateException, CiliaIllegalParameterException
ModelComponents
getProperties
in interface ModelComponents
CiliaIllegalStateException
CiliaIllegalParameterException
public Object getProperty(Node node, String key) throws CiliaIllegalStateException, CiliaIllegalParameterException
ModelComponents
getProperty
in interface ModelComponents
CiliaIllegalStateException
CiliaIllegalParameterException
public void addListener(String ldapFilter, NodeCallback listener) throws CiliaIllegalParameterException, CiliaInvalidSyntaxException
addListener
in interface NodeRegistration
listener
- , listener to addCiliaIllegalParameterException
- , null of wrong parameterCiliaInvalidSyntaxException
- LDAP syntax errorpublic void removeListener(NodeCallback listener) throws CiliaIllegalParameterException
removeListener
in interface NodeRegistration
listener
- , listener to removeCiliaIllegalParameterException
- , null parameterpublic void addListener(String ldapFilter, ChainCallback listener) throws CiliaIllegalParameterException, CiliaInvalidSyntaxException
ChainRegistration
addListener
in interface ChainRegistration
listener
- , listener to addCiliaIllegalParameterException
- , null or wrong parameterCiliaInvalidSyntaxException
public void removeListener(ChainCallback listener) throws CiliaIllegalParameterException
ChainRegistration
removeListener
in interface ChainRegistration
listener
- , listener to removeCiliaIllegalParameterException
- is listener is nullpublic void addListener(String ldapfilter, ThresholdsCallback listener) throws CiliaIllegalParameterException, CiliaInvalidSyntaxException
VariablesRegistration
addListener
in interface VariablesRegistration
ldapfilter
- ldap keywords :uuid, chain, node,variablelistener
- ,CiliaIllegalParameterException
CiliaInvalidSyntaxException
public void addListener(String ldapfilter, VariableCallback listener) throws CiliaIllegalParameterException, CiliaInvalidSyntaxException
addListener
in interface VariablesRegistration
ldapfilter
- ldap keywords :uuid,chain, node,variableCiliaIllegalParameterException
CiliaInvalidSyntaxException
public void removeListener(ThresholdsCallback listener) throws CiliaIllegalParameterException
VariablesRegistration
removeListener
in interface VariablesRegistration
listener
- , listener to removeCiliaIllegalParameterException
public void removeListener(VariableCallback listener) throws CiliaIllegalParameterException
VariablesRegistration
removeListener
in interface VariablesRegistration
CiliaIllegalParameterException
public void startChain(String chainId) throws CiliaIllegalParameterException, CiliaIllegalStateException
ApplicationRuntime
startChain
in interface ApplicationRuntime
chainId
- the chain ID to initializeCiliaIllegalParameterException
- when the chain ID does not exist.CiliaIllegalStateException
public void stopChain(String chainId) throws CiliaIllegalParameterException, CiliaIllegalStateException
ApplicationRuntime
stopChain
in interface ApplicationRuntime
chainId
- The chain id to stop.CiliaIllegalParameterException
- when the chain ID does not exist.CiliaIllegalStateException
public SetUp nodeSetup(Node node) throws CiliaIllegalParameterException, CiliaIllegalStateException
ApplicationRuntime
nodeSetup
in interface ApplicationRuntime
CiliaIllegalParameterException
- if the node is nullCiliaIllegalStateException
public int getChainState(String chainId) throws CiliaIllegalParameterException, CiliaIllegalStateException
ApplicationRuntime
getChainState
in interface ApplicationRuntime
CiliaIllegalParameterException
- ,CiliaIllegalStateExceptionCiliaIllegalStateException
public Date lastCommand(String chainId) throws CiliaIllegalParameterException, CiliaIllegalStateException
ApplicationRuntime
lastCommand
in interface ApplicationRuntime
CiliaIllegalParameterException
CiliaIllegalStateException
public SetUp[] nodeSetup(String ldapFilter) throws CiliaIllegalParameterException, CiliaInvalidSyntaxException
nodeSetup
in interface ApplicationRuntime
ldapFilter
- ldap filters, keywords {uuid,chain,node}CiliaInvalidSyntaxException
CiliaIllegalParameterException
public RawData[] nodeRawData(String ldapFilter) throws CiliaInvalidSyntaxException, CiliaIllegalParameterException
nodeRawData
in interface ApplicationRuntime
ldapFilter
- ldap filters, keywords {uuid,chain,node}CiliaInvalidSyntaxException
CiliaIllegalParameterException
public RawData nodeRawData(Node node) throws CiliaIllegalParameterException, CiliaIllegalStateException
ApplicationRuntime
nodeRawData
in interface ApplicationRuntime
CiliaIllegalParameterException
- if the node is nullCiliaIllegalStateException
public Thresholds[] nodeMonitoring(String ldapFilter) throws CiliaIllegalParameterException, CiliaInvalidSyntaxException
nodeMonitoring
in interface ApplicationRuntime
ldapFilter
- ldap filters, keywords {uuid,chain,node}CiliaIllegalParameterException
CiliaInvalidSyntaxException
public Thresholds nodeMonitoring(Node node) throws CiliaIllegalParameterException, CiliaIllegalStateException
ApplicationRuntime
nodeMonitoring
in interface ApplicationRuntime
CiliaIllegalParameterException
- if the node is nullCiliaIllegalStateException
public Map getBufferedData(Node node) throws CiliaIllegalParameterException
ApplicationRuntime
getBufferedData
in interface ApplicationRuntime
node
- the node to retrieve the dataCiliaIllegalParameterException
public boolean copyData(Node from, Node to) throws CiliaIllegalParameterException
ApplicationRuntime
copyData
in interface ApplicationRuntime
from
- The node from the buffered data will be copied.to
- The node to the buffered data will be copied.CiliaIllegalParameterException
Copyright © 2012-2013 Adele Team | LIG. All Rights Reserved.