Package com.adaptris.aws2.kinesis

Class SplittingRequestBuilder

java.lang.Object

com.adaptris.aws2.kinesis.SplittingRequestBuilder

All Implemented Interfaces:

RequestBuilder

public class SplittingRequestBuilder
extends Object
implements RequestBuilder

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

In the adapter configuration file this class is aliased as aws-kinesis-splitting-request-builder which is the preferred alternative to the fully qualified classname when building your configuration.

Constructor Summary

Constructors

Constructor	Description
SplittingRequestBuilder()

Method Summary

Modifier and Type	Method	Description
Iterable<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>	build(String partitionKey, AdaptrisMessage message)
@NonNull MessageSplitter	getMessageSplitter()	The message splitter implementation that splits the message into appropriate kinesis records.
void	setMessageSplitter(@NonNull MessageSplitter messageSplitter)	The message splitter implementation that splits the message into appropriate kinesis records.
SplittingRequestBuilder	withMessageSplitter(MessageSplitter s)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SplittingRequestBuilder

public SplittingRequestBuilder()

Method Details

withMessageSplitter

public SplittingRequestBuilder withMessageSplitter(MessageSplitter s)

build

public Iterable<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry> build(String partitionKey,
 AdaptrisMessage message)
                                                                                     throws CoreException

Specified by:

build in interface RequestBuilder

Throws:

CoreException

getMessageSplitter

@NonNull
public @NonNull MessageSplitter getMessageSplitter()

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

setMessageSplitter

public void setMessageSplitter(@NonNull
 @NonNull MessageSplitter messageSplitter)

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