org.apache.camel.component.aws.kinesis

Class KinesisConfiguration

java.lang.Object

org.apache.camel.component.aws.kinesis.KinesisConfiguration

All Implemented Interfaces:

Cloneable

@UriParams
public class KinesisConfiguration
extends Object
implements Cloneable

Constructor Summary

Constructors

Constructor and Description
KinesisConfiguration()

Method Summary

Modifier and Type	Method and Description
KinesisConfiguration	copy()
String	getAccessKey()
com.amazonaws.services.kinesis.AmazonKinesis	getAmazonKinesisClient()
com.amazonaws.services.kinesis.model.ShardIteratorType	getIteratorType()
int	getMaxResultsPerRequest()
String	getProxyHost()
Integer	getProxyPort()
com.amazonaws.Protocol	getProxyProtocol()
String	getRegion()
String	getSecretKey()
String	getSequenceNumber()
KinesisShardClosedStrategyEnum	getShardClosed()
String	getShardId()
String	getStreamName()
boolean	isAutoDiscoverClient()
void	setAccessKey(String accessKey)
void	setAmazonKinesisClient(com.amazonaws.services.kinesis.AmazonKinesis amazonKinesisClient)
void	setAutoDiscoverClient(boolean autoDiscoverClient)
void	setIteratorType(com.amazonaws.services.kinesis.model.ShardIteratorType iteratorType)
void	setMaxResultsPerRequest(int maxResultsPerRequest)
void	setProxyHost(String proxyHost)
void	setProxyPort(Integer proxyPort)
void	setProxyProtocol(com.amazonaws.Protocol proxyProtocol)
void	setRegion(String region)
void	setSecretKey(String secretKey)
void	setSequenceNumber(String sequenceNumber)
void	setShardClosed(KinesisShardClosedStrategyEnum shardClosed)
void	setShardId(String shardId)
void	setStreamName(String streamName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KinesisConfiguration

public KinesisConfiguration()

Method Detail

getAmazonKinesisClient

public com.amazonaws.services.kinesis.AmazonKinesis getAmazonKinesisClient()

setAmazonKinesisClient

public void setAmazonKinesisClient(com.amazonaws.services.kinesis.AmazonKinesis amazonKinesisClient)

getMaxResultsPerRequest

public int getMaxResultsPerRequest()

setMaxResultsPerRequest

public void setMaxResultsPerRequest(int maxResultsPerRequest)

getStreamName

public String getStreamName()

setStreamName

public void setStreamName(String streamName)

getIteratorType

public com.amazonaws.services.kinesis.model.ShardIteratorType getIteratorType()

setIteratorType

public void setIteratorType(com.amazonaws.services.kinesis.model.ShardIteratorType iteratorType)

getShardId

public String getShardId()

setShardId

public void setShardId(String shardId)

getSequenceNumber

public String getSequenceNumber()

setSequenceNumber

public void setSequenceNumber(String sequenceNumber)

getShardClosed

public KinesisShardClosedStrategyEnum getShardClosed()

setShardClosed

public void setShardClosed(KinesisShardClosedStrategyEnum shardClosed)

getAccessKey

public String getAccessKey()

setAccessKey

public void setAccessKey(String accessKey)

getSecretKey

public String getSecretKey()

setSecretKey

public void setSecretKey(String secretKey)

getRegion

public String getRegion()

setRegion

public void setRegion(String region)

getProxyProtocol

public com.amazonaws.Protocol getProxyProtocol()

setProxyProtocol

public void setProxyProtocol(com.amazonaws.Protocol proxyProtocol)

getProxyHost

public String getProxyHost()

setProxyHost

public void setProxyHost(String proxyHost)

getProxyPort

public Integer getProxyPort()

setProxyPort

public void setProxyPort(Integer proxyPort)

isAutoDiscoverClient

public boolean isAutoDiscoverClient()

setAutoDiscoverClient

public void setAutoDiscoverClient(boolean autoDiscoverClient)

copy

public KinesisConfiguration copy()