Index

A B C D E G I K P R S W
All Classes and Interfaces|All Packages|Constant Field Values

A

AWSKinesisSDKConnection - Class in com.adaptris.aws2.kinesis

AdaptrisConnection implementation for Amazon Kinesis using the SDK.

AWSKinesisSDKConnection() - Constructor for class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

B

build(String, AdaptrisMessage) - Method in class com.adaptris.aws2.kinesis.DefaultRequestBuilder

build(String, AdaptrisMessage) - Method in interface com.adaptris.aws2.kinesis.RequestBuilder

build(String, AdaptrisMessage) - Method in class com.adaptris.aws2.kinesis.SplittingRequestBuilder

C

closeConnection() - Method in class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

com.adaptris.aws2.kinesis - package com.adaptris.aws2.kinesis

createBuilder() - Method in class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

D

DefaultRequestBuilder - Class in com.adaptris.aws2.kinesis

The default request builder.

DefaultRequestBuilder() - Constructor for class com.adaptris.aws2.kinesis.DefaultRequestBuilder

doProduce(AdaptrisMessage, String) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

doSend(KinesisClient, String, List<PutRecordsRequestEntry>) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

E

endpoint(AdaptrisMessage) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

G

getBatchWindow() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

Batch window controls on how the records are put to the stream, this used in conjunction with a splitting implementation of the request builder.

getCreateIfNotExists() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

Toggles whether to create the stream if it does not exist at the time of sending

getCreateStreamMaxWaitTimeMillis() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

getCreateStreamPollTimeMillis() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

getMessageSplitter() - Method in class com.adaptris.aws2.kinesis.SplittingRequestBuilder

The message splitter implementation that splits the message into appropriate kinesis records.

getPartitionKey() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

The kinesis partition key.

getRequestBuilder() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

Request Builder enables the control on how the records are put, this is used in conjunction with batchWindow.

getShardCount() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

If creating a stream, this specifies the number of shards for StreamMode.PROVISIONED.

getStream() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

The kinesis stream name.

I

initConnection() - Method in class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

K

kinesisClient() - Method in class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

KinesisSDKStreamProducer - Class in com.adaptris.aws2.kinesis

Producer to amazon kinesis using the SDK.

KinesisSDKStreamProducer() - Constructor for class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

P

prepare() - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

prepareConnection() - Method in class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

R

RequestBuilder - Interface in com.adaptris.aws2.kinesis

S

setBatchWindow(Integer) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

Batch window controls on how the records are put to the stream, this used in conjunction with a splitting implementation of the request builder.

setCreateIfNotExists(boolean) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

Toggles whether to create the stream if it does not exist at the time of sending

setCreateStreamMaxWaitTimeMillis(long) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

setCreateStreamPollTimeMillis(long) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

setMessageSplitter(MessageSplitter) - Method in class com.adaptris.aws2.kinesis.SplittingRequestBuilder

The message splitter implementation that splits the message into appropriate kinesis records.

setPartitionKey(String) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

setRequestBuilder(RequestBuilder) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

Request Builder enables the control on how the records are put, this is used in conjunction with batchWindow.

setShardCount(int) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

If creating a stream, this specifies the number of shards for StreamMode.PROVISIONED.

setStream(String) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

The kinesis stream name.

SHARD_COUNT_NONE - Static variable in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

SplittingRequestBuilder - Class in com.adaptris.aws2.kinesis

Request Builder implementation that allows you to split the message into a number of PutRecordsRequestEntry records.

SplittingRequestBuilder() - Constructor for class com.adaptris.aws2.kinesis.SplittingRequestBuilder

startConnection() - Method in class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

stopConnection() - Method in class com.adaptris.aws2.kinesis.AWSKinesisSDKConnection

W

withBatchWindow(Integer) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

withCreateIfNotExists(boolean) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

withCreateStreamMaxWaitTimeMillis(long) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

If createIfNotExists is true, when creating the stream, this is the max wait time for the stream to become active

withCreateStreamPollTimeMillis(long) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

If createIfNotExists is true, when creating the stream, this is the wait time between polling to check if the stream is active

withMessageSplitter(MessageSplitter) - Method in class com.adaptris.aws2.kinesis.SplittingRequestBuilder

withPartitionKey(String) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

withRequestBuilder(RequestBuilder) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

withShardCount(int) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

If createIfNotExists is true, when creating the stream, this is the shard count

withStream(String) - Method in class com.adaptris.aws2.kinesis.KinesisSDKStreamProducer

A B C D E G I K P R S W
All Classes and Interfaces|All Packages|Constant Field Values