A B C D F G I K L O P R S T V
All Classes All Packages
All Classes All Packages
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
All Classes All Packages