A B C D E G I K M N O P R S T
All Classes All Packages

A

asList() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.CustomSettings

asSingleValueMap() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.CustomSettings

B

build() - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Create a new OutboundKinesisRecord from the current state of this builder.

C

com.hivemq.extensions.amazon.kinesis.api.builders - package com.hivemq.extensions.amazon.kinesis.api.builders

com.hivemq.extensions.amazon.kinesis.api.model - package com.hivemq.extensions.amazon.kinesis.api.model

com.hivemq.extensions.amazon.kinesis.api.transformers - package com.hivemq.extensions.amazon.kinesis.api.transformers

CustomSetting - Interface in com.hivemq.extensions.amazon.kinesis.api.model

A representation for a custom setting.

CustomSettings - Interface in com.hivemq.extensions.amazon.kinesis.api.model

This interface provides information about <custom-settings> as it is configured in the amazon-kinesis-configuration.xml.

D

data(byte[]) - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the data of the Amazon Kinesis record.

data(String) - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the data of the Amazon Kinesis record.

data(String, Charset) - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the data of the Amazon Kinesis record.

data(ByteBuffer) - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the data of the Amazon Kinesis record.

E

explicitHashKey(BigInteger) - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the explicitHashKey of the Amazon Kinesis record.

G

getAllForName(String) - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.CustomSettings

getApproximateArrivalTimestamp() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.InboundKinesisRecord

getCustomSettings() - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.TransformerInput

getData() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.KinesisRecord

getDataAsByteArray() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.KinesisRecord

getEncryptionType() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.InboundKinesisRecord

getExplicitHashKey() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.OutboundKinesisRecord

getFirst(String) - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.CustomSettings

getInboundKinesisRecord() - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.KinesisToMqttInput

getMetricRegistry() - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.TransformerInput

Get the MetricRegistry of this HiveMQ node.

getName() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.CustomSetting

getPartitionKey() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.KinesisRecord

getPublishPacket() - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.MqttToKinesisInput

getSequenceNumber() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.InboundKinesisRecord

getStreamName() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.KinesisRecord

getValue() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.CustomSetting

I

InboundKinesisRecord - Interface in com.hivemq.extensions.amazon.kinesis.api.model

Represents an inbound Amazon Kinesis record that was read from Kinesis.

init(KinesisToMqttInitInput) - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.KinesisToMqttTransformer

Override the init method to initialize the transformer.

init(MqttToKinesisInitInput) - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.MqttToKinesisTransformer

Override the init method to initialize the transformer.

isEmpty() - Method in interface com.hivemq.extensions.amazon.kinesis.api.model.CustomSettings

K

KinesisRecord - Interface in com.hivemq.extensions.amazon.kinesis.api.model

Represents an Amazon Kinesis record.

KinesisToMqttInitInput - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

Provides context for the initialization of a KinesisToMqttTransformer.

KinesisToMqttInput - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

The input parameter of the KinesisToMqttTransformer.

KinesisToMqttOutput - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

The output parameter of the KinesisToMqttTransformer.

KinesisToMqttTransformer - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

Implement this transformer for the programmatic creation of Publishes from InboundKinesisRecords.

M

MqttToKinesisInitInput - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

Provides context for the initialization of a MqttToKinesisTransformer.

MqttToKinesisInput - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

The input parameter of the MqttToKinesisTransformer.

MqttToKinesisOutput - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

The output parameter of the MqttToKinesisTransformer.

MqttToKinesisTransformer - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

Implement this transformer for the programmatic creation of OutboundKinesisRecords from PublishPackets.

N

newOutboundKinesisRecordBuilder() - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.MqttToKinesisOutput

Create a new OutboundKinesisRecordBuilder.

newPublishBuilder() - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.KinesisToMqttOutput

O

OutboundKinesisRecord - Interface in com.hivemq.extensions.amazon.kinesis.api.model

Represents an outbound Amazon Kinesis record, that should be written to Kinesis.

OutboundKinesisRecordBuilder - Interface in com.hivemq.extensions.amazon.kinesis.api.builders

The OutboundKinesisRecordBuilder enables the creation of OutboundKinesisRecords via its fluent API.

P

partitionKey(String) - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the partitionKey of the Amazon Kinesis record.

R

randomExplicitHashKey() - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the explicitHashKey of the Amazon Kinesis record to a random value.

randomPartitionKey() - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the partitionKey of the Amazon Kinesis record to a random value.

S

setOutboundKinesisRecords(List<OutboundKinesisRecord>) - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.MqttToKinesisOutput

Sets the OutboundKinesisRecords, that will be pushed to Amazon Kinesis after the MqttToKinesisTransformer.transformMqttToKinesis(MqttToKinesisInput, MqttToKinesisOutput) call returns.

setPublishes(List<Publish>) - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.KinesisToMqttOutput

Sets the Publishes, that will be published by HiveMQ after the KinesisToMqttTransformer.transformKinesisToMqtt(KinesisToMqttInput, KinesisToMqttOutput) call returns.

streamName(String) - Method in interface com.hivemq.extensions.amazon.kinesis.api.builders.OutboundKinesisRecordBuilder

Set the streamName of the Amazon Kinesis record.

T

TransformerInput - Interface in com.hivemq.extensions.amazon.kinesis.api.transformers

The general interface for the input objects.

transformKinesisToMqtt(KinesisToMqttInput, KinesisToMqttOutput) - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.KinesisToMqttTransformer

This callback is executed for every InboundKinesisRecord that the "HiveMQ Enterprise Extension for Amazon Kinesis" polls from Amazon Kinesis according to the configured <kinesis-streams> in the <kinesis-to-mqtt-route> tag.

transformMqttToKinesis(MqttToKinesisInput, MqttToKinesisOutput) - Method in interface com.hivemq.extensions.amazon.kinesis.api.transformers.MqttToKinesisTransformer

This callback is executed for every MQTT PUBLISH that arrives at your HiveMQ cluster matching the <mqtt-topic-filters> tag configured in the <mqtt-to-kinesis-route>.

A B C D E G I K M N O P R S T
All Classes All Packages