org.apache.camel.component.jclouds
Class JcloudsBlobStoreProducer
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultProducer
org.apache.camel.component.jclouds.JcloudsProducer
org.apache.camel.component.jclouds.JcloudsBlobStoreProducer
- All Implemented Interfaces:
- org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class JcloudsBlobStoreProducer
- extends JcloudsProducer
Fields inherited from class org.apache.camel.impl.DefaultProducer |
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Method Summary |
protected void |
doStart()
|
protected String |
getBlobName(org.apache.camel.Exchange exchange)
Retrieves the blobName from the URI or from the exchange headers. |
protected String |
getContainerName(org.apache.camel.Exchange exchange)
Retrieves the containerName from the URI or from the exchange headers. |
String |
getLocationId(org.apache.camel.Exchange exchange)
Retrieves the locationId 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. |
void |
process(org.apache.camel.Exchange exchange)
|
Methods inherited from class org.apache.camel.impl.DefaultProducer |
createExchange, createExchange, createExchange, doStop, getEndpoint, isSingleton, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
JcloudsBlobStoreProducer
public JcloudsBlobStoreProducer(JcloudsBlobStoreEndpoint endpoint,
org.jclouds.blobstore.BlobStore blobStore)
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultProducer
- Throws:
Exception
process
public void process(org.apache.camel.Exchange exchange)
throws Exception
- Specified by:
process
in interface org.apache.camel.Processor
- Overrides:
process
in class JcloudsProducer
- Throws:
Exception
getBlobName
protected String getBlobName(org.apache.camel.Exchange exchange)
- Retrieves the blobName from the URI or from the exchange headers. The header will take precedence over the URI.
- Parameters:
exchange
-
- Returns:
getContainerName
protected String getContainerName(org.apache.camel.Exchange exchange)
- Retrieves the containerName from the URI or from the exchange headers. The header will take precedence over the URI.
- Parameters:
exchange
-
- Returns:
getOperation
public String getOperation(org.apache.camel.Exchange exchange)
- Retrieves the operation from the URI or from the exchange headers. The header will take precedence over the URI.
- Parameters:
exchange
-
- Returns:
getLocationId
public String getLocationId(org.apache.camel.Exchange exchange)
- Retrieves the locationId from the URI or from the exchange headers. The header will take precedence over the URI.
- Parameters:
exchange
-
- Returns:
Apache CAMEL