public class JcloudsComputeProducer extends JcloudsProducer
Constructor and Description |
---|
JcloudsComputeProducer(JcloudsEndpoint endpoint,
org.jclouds.compute.ComputeService computeService) |
Modifier and Type | Method and Description |
---|---|
protected void |
createNode(org.apache.camel.Exchange exchange)
Create a node with the specified group.
|
protected void |
destroyNode(org.apache.camel.Exchange exchange)
Destroys the node with the specified nodeId.
|
com.google.common.base.Predicate<org.jclouds.compute.domain.ComputeMetadata> |
getComputePredicate(org.apache.camel.Exchange exchange)
Returns the required
Predicate for the Exhcnage. |
JcloudsComputeEndpoint |
getEndpoint() |
protected String |
getGroup(org.apache.camel.Exchange exchange)
Retrieves the group from the URI or from the exchange headers.
|
protected String |
getHardwareId(org.apache.camel.Exchange exchange)
Retrieves the hardware id from the URI or from the exchange headers.
|
protected String |
getImageId(org.apache.camel.Exchange exchange)
Retrieves the image id from the URI or from the exchange properties.
|
protected String |
getLocationId(org.apache.camel.Exchange exchange)
Retrieves the location id from the URI or from the exchange headers.
|
protected String |
getNodeId(org.apache.camel.Exchange exchange)
Retrieves the node id from the URI or from the exchange headers.
|
com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> |
getNodePredicate(org.apache.camel.Exchange exchange)
Returns the required
Predicate for the Exhcnage. |
org.jclouds.compute.domain.NodeMetadata.Status |
getNodeState(org.apache.camel.Exchange exchange)
Retrieves the node state from the URI or from the exchange headers.
|
String |
getOperation(org.apache.camel.Exchange exchange)
Retrieves the operation from the URI or from the exchange headers.
|
protected String |
getUser(org.apache.camel.Exchange exchange)
Retrieves the user from the URI or from the exchange headers.
|
protected void |
listHardware(org.apache.camel.Exchange exchange)
Sets the available hardware profiles to the out message.
|
protected void |
listImages(org.apache.camel.Exchange exchange)
Sets the available images to the out message.
|
protected void |
listNodes(org.apache.camel.Exchange exchange)
Sets the metadata of the available nodes to the out message.
|
void |
process(org.apache.camel.Exchange exchange) |
protected void |
rebootNode(org.apache.camel.Exchange exchange)
Reboot the node with the specified nodeId.
|
protected void |
resumeNode(org.apache.camel.Exchange exchange)
Suspend the node with the specified nodeId.
|
protected void |
runScriptOnNode(org.apache.camel.Exchange exchange)
Runs a script on the target node.
|
protected void |
suspendNode(org.apache.camel.Exchange exchange)
Suspend the node with the specified nodeId.
|
createExchange, createExchange, createExchange, doStart, doStop, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public JcloudsComputeProducer(JcloudsEndpoint endpoint, org.jclouds.compute.ComputeService computeService)
public JcloudsComputeEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
protected void createNode(org.apache.camel.Exchange exchange) throws org.apache.camel.CamelException
org.apache.camel.CamelException
protected void runScriptOnNode(org.apache.camel.Exchange exchange) throws org.apache.camel.CamelException
org.apache.camel.CamelException
protected void destroyNode(org.apache.camel.Exchange exchange)
protected void listNodes(org.apache.camel.Exchange exchange)
protected void listImages(org.apache.camel.Exchange exchange)
protected void listHardware(org.apache.camel.Exchange exchange)
protected void rebootNode(org.apache.camel.Exchange exchange)
protected void suspendNode(org.apache.camel.Exchange exchange)
protected void resumeNode(org.apache.camel.Exchange exchange)
public com.google.common.base.Predicate<org.jclouds.compute.domain.ComputeMetadata> getComputePredicate(org.apache.camel.Exchange exchange)
Predicate
for the Exhcnage.
The predicate can be used for filtering.public com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> getNodePredicate(org.apache.camel.Exchange exchange)
Predicate
for the Exhcnage.
The predicate can be used for filtering.public String getOperation(org.apache.camel.Exchange exchange)
public org.jclouds.compute.domain.NodeMetadata.Status getNodeState(org.apache.camel.Exchange exchange)
protected String getImageId(org.apache.camel.Exchange exchange)
protected String getHardwareId(org.apache.camel.Exchange exchange)
protected String getLocationId(org.apache.camel.Exchange exchange)
protected String getNodeId(org.apache.camel.Exchange exchange)
protected String getGroup(org.apache.camel.Exchange exchange)
protected String getUser(org.apache.camel.Exchange exchange)
Apache Camel