A C D G K L O P R S T V

A

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

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

G

getAccessKey() - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration

getAccessKey() - Method in class org.apache.camel.component.aws.kinesis.KinesisConfiguration

getAllOptions(Object) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseComponentConfigurer

getAllOptions(Object) - Method in class org.apache.camel.component.aws.firehose.KinesisFirehoseEndpointConfigurer

getAllOptions(Object) - Method in class org.apache.camel.component.aws.kinesis.KinesisComponentConfigurer

getAllOptions(Object) - Method in class org.apache.camel.component.aws.kinesis.KinesisEndpointConfigurer

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

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

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

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

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

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

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

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

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

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 C D G K L O P R S T V