org.apache.camel.component.aws.s3
Class S3Endpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.impl.ScheduledPollEndpoint
              extended by 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.


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
S3Endpoint(String uri, org.apache.camel.CamelContext context, S3Configuration configuration)
          Deprecated. 
S3Endpoint(String uri, org.apache.camel.Component comp, S3Configuration configuration)
           
 
Method Summary
 org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
           
 org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern pattern, com.amazonaws.services.s3.model.S3Object s3Object)
           
 org.apache.camel.Exchange createExchange(com.amazonaws.services.s3.model.S3Object s3Object)
           
 org.apache.camel.Producer createProducer()
           
 void doStart()
           
 S3Configuration getConfiguration()
           
 int getMaxMessagesPerPoll()
           
 com.amazonaws.services.s3.AmazonS3 getS3Client()
           
 boolean isSingleton()
           
 void setConfiguration(S3Configuration configuration)
           
 void setMaxMessagesPerPoll(int maxMessagesPerPoll)
           
 void setS3Client(com.amazonaws.services.s3.AmazonS3 s3Client)
           
 
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 class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

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)
Method Detail

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