public class JcloudsBlobStoreEndpoint extends JcloudsEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Constructor and Description |
---|
JcloudsBlobStoreEndpoint(String uri,
JcloudsComponent component,
org.jclouds.blobstore.BlobStore blobStore) |
Modifier and Type | Method and Description |
---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
getBlobName, getCommand, getConfiguration, getContainer, getDirectory, getGroup, getHardwareId, getImageId, getLocationId, getNodeId, getNodeState, getOperation, getProviderId, getUser, isSingleton, setBlobName, setCommand, setConfiguration, setContainer, setDirectory, setGroup, setHardwareId, setImageId, setLocationId, setNodeId, setNodeState, setOperation, setProviderId, setUser
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public JcloudsBlobStoreEndpoint(String uri, JcloudsComponent component, org.jclouds.blobstore.BlobStore blobStore)
public Producer createProducer() throws Exception
Endpoint
Exception
- can be thrownpublic Consumer createConsumer(Processor processor) throws Exception
Endpoint
processor
- the given processorException
- can be thrownCopyright © 2007–2016 The Apache Software Foundation. All rights reserved.