org.apache.camel.component.aws.s3
Class S3Endpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.impl.ScheduledPollEndpoint
org.apache.camel.component.aws.s3.S3Endpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class S3Endpoint
- extends org.apache.camel.impl.ScheduledPollEndpoint
Defines the AWS S3 Endpoint.
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
S3Endpoint
@Deprecated
public S3Endpoint(String uri,
org.apache.camel.CamelContext context,
S3Configuration configuration)
- Deprecated.
S3Endpoint
public S3Endpoint(String uri,
org.apache.camel.Component comp,
S3Configuration configuration)
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
isSingleton
public boolean isSingleton()
doStart
public void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
createExchange
public org.apache.camel.Exchange createExchange(com.amazonaws.services.s3.model.S3Object s3Object)
createExchange
public org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern pattern,
com.amazonaws.services.s3.model.S3Object s3Object)
getConfiguration
public S3Configuration getConfiguration()
setConfiguration
public void setConfiguration(S3Configuration configuration)
setS3Client
public void setS3Client(com.amazonaws.services.s3.AmazonS3 s3Client)
getS3Client
public com.amazonaws.services.s3.AmazonS3 getS3Client()
getMaxMessagesPerPoll
public int getMaxMessagesPerPoll()
setMaxMessagesPerPoll
public void setMaxMessagesPerPoll(int maxMessagesPerPoll)
Apache Camel