A B C D F G I K L O P R S T V 
All Classes All Packages

A

APPROX_ARRIVAL_TIME - Static variable in interface org.apache.camel.component.aws.kinesis.KinesisConstants
 

B

buildUri(String, Map<String, Object>, boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointUriFactory
 
buildUri(String, Map<String, Object>, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointUriFactory
 

C

configure(CamelContext, Object, String, Object, boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentConfigurer
 
configure(CamelContext, Object, String, Object, boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointConfigurer
 
configure(CamelContext, Object, String, Object, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponentConfigurer
 
configure(CamelContext, Object, String, Object, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointConfigurer
 
copy() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
copy() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
createConsumer(Processor) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpoint
 
createConsumer(Processor) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 
createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponent
 
createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponent
 
createExchange(Record) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 
createProducer() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpoint
 
createProducer() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 

D

doStart() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpoint
 
doStart() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 
doStop() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpoint
 
doStop() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 

F

fail - org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum
 

G

getAccessKey() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getAccessKey() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getAmazonKinesisClient() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getAmazonKinesisFirehoseClient() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getClient() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpoint
 
getClient() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 
getCollectionValueType(Object, String, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointConfigurer
 
getConfiguration() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponent
 
getConfiguration() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpoint
 
getConfiguration() - Method in class org.apache.camel.component.aws.kinesis.KinesisComponent
 
getConfiguration() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 
getEndpoint() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseProducer
 
getEndpoint() - Method in class org.apache.camel.component.aws.kinesis.KinesisConsumer
 
getEndpoint() - Method in class org.apache.camel.component.aws.kinesis.KinesisProducer
 
getIteratorType() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getMaxResultsPerRequest() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getMessageForResponse(Exchange) - Static method in class org.apache.camel.component.aws.firehose.KinesisFirehoseProducer
 
getMessageForResponse(Exchange) - Static method in class org.apache.camel.component.aws.kinesis.KinesisProducer
 
getOptionType(String, boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentConfigurer
 
getOptionType(String, boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointConfigurer
 
getOptionType(String, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponentConfigurer
 
getOptionType(String, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointConfigurer
 
getOptionValue(Object, String, boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentConfigurer
 
getOptionValue(Object, String, boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointConfigurer
 
getOptionValue(Object, String, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponentConfigurer
 
getOptionValue(Object, String, boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointConfigurer
 
getProxyHost() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getProxyHost() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getProxyPort() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getProxyPort() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getProxyProtocol() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getProxyProtocol() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getRegion() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getRegion() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getSecretKey() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getSecretKey() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getSequenceNumber() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getShardClosed() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getShardId() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
getStreamName() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
getStreamName() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 

I

ignore - org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum
 
isAutoDiscoverClient() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
isAutoDiscoverClient() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
isEnabled(String) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointUriFactory
 
isEnabled(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointUriFactory
 
isLenientProperties() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointUriFactory
 
isLenientProperties() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointUriFactory
 

K

KinesisComponent - Class in org.apache.camel.component.aws.kinesis
 
KinesisComponent() - Constructor for class org.apache.camel.component.aws.kinesis.KinesisComponent
 
KinesisComponent(CamelContext) - Constructor for class org.apache.camel.component.aws.kinesis.KinesisComponent
 
KinesisComponentConfigurer - Class in org.apache.camel.component.aws.kinesis
Generated by camel build tools - do NOT edit this file!
KinesisComponentConfigurer() - Constructor for class org.apache.camel.component.aws.kinesis.KinesisComponentConfigurer
 
KinesisComponentVerifierExtension - Class in org.apache.camel.component.aws.kinesis
 
KinesisComponentVerifierExtension() - Constructor for class org.apache.camel.component.aws.kinesis.KinesisComponentVerifierExtension
 
KinesisComponentVerifierExtension(String) - Constructor for class org.apache.camel.component.aws.kinesis.KinesisComponentVerifierExtension
 
KinesisConfiguration - Class in org.apache.camel.component.aws.kinesis
 
KinesisConfiguration() - Constructor for class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
KinesisConstants - Interface in org.apache.camel.component.aws.kinesis
 
KinesisConsumer - Class in org.apache.camel.component.aws.kinesis
 
KinesisConsumer(KinesisEndpoint, Processor) - Constructor for class org.apache.camel.component.aws.kinesis.KinesisConsumer
 
KinesisEndpoint - Class in org.apache.camel.component.aws.kinesis
Consume and produce records from AWS Kinesis Streams.
KinesisEndpoint(String, KinesisConfiguration, KinesisComponent) - Constructor for class org.apache.camel.component.aws.kinesis.KinesisEndpoint
 
KinesisEndpointConfigurer - Class in org.apache.camel.component.aws.kinesis
Generated by camel build tools - do NOT edit this file!
KinesisEndpointConfigurer() - Constructor for class org.apache.camel.component.aws.kinesis.KinesisEndpointConfigurer
 
KinesisEndpointUriFactory - Class in org.apache.camel.component.aws.kinesis
Generated by camel build tools - do NOT edit this file!
KinesisEndpointUriFactory() - Constructor for class org.apache.camel.component.aws.kinesis.KinesisEndpointUriFactory
 
KinesisFirehoseComponent - Class in org.apache.camel.component.aws.firehose
 
KinesisFirehoseComponent() - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseComponent
 
KinesisFirehoseComponent(CamelContext) - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseComponent
 
KinesisFirehoseComponentConfigurer - Class in org.apache.camel.component.aws.firehose
Generated by camel build tools - do NOT edit this file!
KinesisFirehoseComponentConfigurer() - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentConfigurer
 
KinesisFirehoseComponentVerifierExtension - Class in org.apache.camel.component.aws.firehose
 
KinesisFirehoseComponentVerifierExtension() - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentVerifierExtension
 
KinesisFirehoseComponentVerifierExtension(String) - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentVerifierExtension
 
KinesisFirehoseConfiguration - Class in org.apache.camel.component.aws.firehose
 
KinesisFirehoseConfiguration() - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
KinesisFirehoseConstants - Interface in org.apache.camel.component.aws.firehose
 
KinesisFirehoseEndpoint - Class in org.apache.camel.component.aws.firehose
Consume data from AWS Kinesis Firehose streams.
KinesisFirehoseEndpoint(String, KinesisFirehoseConfiguration, KinesisFirehoseComponent) - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpoint
 
KinesisFirehoseEndpointConfigurer - Class in org.apache.camel.component.aws.firehose
Generated by camel build tools - do NOT edit this file!
KinesisFirehoseEndpointConfigurer() - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointConfigurer
 
KinesisFirehoseEndpointUriFactory - Class in org.apache.camel.component.aws.firehose
Generated by camel build tools - do NOT edit this file!
KinesisFirehoseEndpointUriFactory() - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointUriFactory
 
KinesisFirehoseProducer - Class in org.apache.camel.component.aws.firehose
 
KinesisFirehoseProducer(KinesisFirehoseEndpoint) - Constructor for class org.apache.camel.component.aws.firehose.KinesisFirehoseProducer
 
KinesisProducer - Class in org.apache.camel.component.aws.kinesis
 
KinesisProducer(KinesisEndpoint) - Constructor for class org.apache.camel.component.aws.kinesis.KinesisProducer
 
KinesisShardClosedStrategyEnum - Enum in org.apache.camel.component.aws.kinesis
 

L

load(TypeConverterRegistry) - Method in class org.apache.camel.component.aws.kinesis.RecordStringConverterLoader
 

O

org.apache.camel.component.aws.firehose - package org.apache.camel.component.aws.firehose
 
org.apache.camel.component.aws.kinesis - package org.apache.camel.component.aws.kinesis
 

P

PARTITION_KEY - Static variable in interface org.apache.camel.component.aws.kinesis.KinesisConstants
 
poll() - Method in class org.apache.camel.component.aws.kinesis.KinesisConsumer
 
process(Exchange) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseProducer
 
process(Exchange) - Method in class org.apache.camel.component.aws.kinesis.KinesisProducer
 
processBatch(Queue<Object>) - Method in class org.apache.camel.component.aws.kinesis.KinesisConsumer
 
propertyNames() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointUriFactory
 
propertyNames() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointUriFactory
 

R

ReachedClosedStatusException - Exception in org.apache.camel.component.aws.kinesis
 
ReachedClosedStatusException(String, String) - Constructor for exception org.apache.camel.component.aws.kinesis.ReachedClosedStatusException
 
RECORD_ID - Static variable in interface org.apache.camel.component.aws.firehose.KinesisFirehoseConstants
 
RecordStringConverter - Class in org.apache.camel.component.aws.kinesis
 
RecordStringConverterLoader - Class in org.apache.camel.component.aws.kinesis
Generated by camel build tools - do NOT edit this file!
RecordStringConverterLoader() - Constructor for class org.apache.camel.component.aws.kinesis.RecordStringConverterLoader
 

S

secretPropertyNames() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointUriFactory
 
secretPropertyNames() - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointUriFactory
 
SEQUENCE_NUMBER - Static variable in interface org.apache.camel.component.aws.kinesis.KinesisConstants
 
setAccessKey(String) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setAccessKey(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setAmazonKinesisClient(AmazonKinesis) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setAmazonKinesisFirehoseClient(AmazonKinesisFirehose) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setAutoDiscoverClient(boolean) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setAutoDiscoverClient(boolean) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setConfiguration(KinesisFirehoseConfiguration) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponent
The component configuration
setConfiguration(KinesisConfiguration) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponent
The component configuration
setIteratorType(ShardIteratorType) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setMaxResultsPerRequest(int) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setProxyHost(String) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setProxyHost(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setProxyPort(Integer) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setProxyPort(Integer) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setProxyProtocol(Protocol) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setProxyProtocol(Protocol) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setRegion(String) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setRegion(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setSecretKey(String) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setSecretKey(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setSequenceNumber(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setShardClosed(KinesisShardClosedStrategyEnum) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setShardId(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
setStreamName(String) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration
 
setStreamName(String) - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration
 
SHARD_ID - Static variable in interface org.apache.camel.component.aws.kinesis.KinesisConstants
in a Kinesis Record object, the shard ID is used on writes to indicate where the data was stored
silent - org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum
 

T

toString(Record) - Static method in class org.apache.camel.component.aws.kinesis.RecordStringConverter
 

V

valueOf(String) - Static method in enum org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum
Returns an array containing the constants of this enum type, in the order they are declared.
verifyConnectivity(Map<String, Object>) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentVerifierExtension
 
verifyConnectivity(Map<String, Object>) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponentVerifierExtension
 
verifyParameters(Map<String, Object>) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentVerifierExtension
 
verifyParameters(Map<String, Object>) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponentVerifierExtension
 
A B C D F G I K L O P R S T V 
All Classes All Packages