A B C D E G I K P R S W
All Classes All Packages

A

AWSKinesisSDKConnection - Class in com.adaptris.aws.kinesis

AdaptrisConnection implementation for Amazon Kinesis using the SDK.

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

B

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

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

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

C

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

com.adaptris.aws.kinesis - package com.adaptris.aws.kinesis

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

D

DefaultRequestBuilder - Class in com.adaptris.aws.kinesis

The default request builder.

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

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

E

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

G

getBatchWindow() - Method in class com.adaptris.aws.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.

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

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

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

The kinesis partition key.

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

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

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

The kinesis stream name.

I

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

K

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

KinesisSDKStreamProducer - Class in com.adaptris.aws.kinesis

Producer to amazon kinesis using the SDK.

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

P

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

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

R

RequestBuilder - Interface in com.adaptris.aws.kinesis

S

setBatchWindow(Integer) - Method in class com.adaptris.aws.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.

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

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

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

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

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

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

The kinesis stream name.

SplittingRequestBuilder - Class in com.adaptris.aws.kinesis

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

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

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

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

W

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

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

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

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

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

A B C D E G I K P R S W
All Classes All Packages