Class KinesisConfiguration
- java.lang.Object
-
- org.apache.camel.component.aws.kinesis.KinesisConfiguration
-
-
Constructor Summary
Constructors Constructor Description KinesisConfiguration()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
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()
-
-