C D G I M O S

C

connectionLost(Throwable) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Implements the MqttCallback.connectionLost(Throwable) callback method for the MQTT client to inform the streamer that the connection has been lost.

D

deliveryComplete(IMqttDeliveryToken) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Empty implementation of MqttCallback.deliveryComplete(IMqttDeliveryToken).

G

getBrokerUrl() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the broker URL.

getClientId() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the client ID, either the one set by the user or the automatically generated one.

getConnectOptions() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the currently used MQTT client connect options.

getDisconnectForciblyTimeout() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the timeout if disconnecting forcibly.

getDisconnectQuiesceTimeout() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the disconnect quiesce timeout.

getPersistence() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the currently set persistence mechanism.

getQualitiesOfService() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the qualities of service for multiple topics.

getQualityOfService() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the quality of service set by the user for a single topic consumption.

getRetryStopStrategy() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the retry stop strategy.

getRetryWaitStrategy() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the retry wait strategy.

getTopic() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the subscribed topic.

getTopics() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets the topics subscribed to.

I

isBlockUntilConnected() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets whether to block the start() method until connected for the first time.

isConnected() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Returns whether this streamer is connected by delegating to the underlying MqttClient.isConnected()

isDisconnectForcibly() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Gets whether this MQTT client will disconnect forcibly when shutting down.

isStopped() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Returns whether this streamer is stopped.

M

messageArrived(String, MqttMessage) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Implements the MqttCallback.messageArrived(String, MqttMessage) to receive an MQTT message.

MqttStreamer<K,V> - Class in org.apache.ignite.stream.mqtt

Streamer that consumes from a MQTT topic and feeds key-value pairs into an IgniteDataStreamer instance, using Eclipse Paho as an MQTT client.

MqttStreamer() - Constructor for class org.apache.ignite.stream.mqtt.MqttStreamer

O

org.apache.ignite.stream.mqtt - package org.apache.ignite.stream.mqtt

Contains implementation of MQTT topic messages consumer.

S

setBlockUntilConnected(boolean) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets whether to block the start() method until connected for the first time.

setBrokerUrl(String) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the broker URL (compulsory).

setClientId(String) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the MQTT client ID (optional).

setConnectOptions(MqttConnectOptions) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the MQTT client connect options, where users can configured the last will and testament, durability, etc.

setDisconnectForcibly(boolean) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets whether to disconnect forcibly or not when shutting down.

setDisconnectForciblyTimeout(Integer) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the timeout if disconnecting forcibly.

setDisconnectQuiesceTimeout(Integer) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the quiesce timeout on disconnection.

setPersistence(MqttClientPersistence) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the persistence mechanism.

setQualitiesOfService(List<Integer>) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the qualities of service to use for multiple topic subscriptions.

setQualityOfService(Integer) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the quality of service to use for a single topic subscription (optional).

setRetryStopStrategy(StopStrategy) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the strategy to determine when to stop retrying to (re-)connect.

setRetryWaitStrategy(WaitStrategy) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the strategy to determine how long to wait between retry attempts.

setTopic(String) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the topic to subscribe to, if a single topic.

setTopics(List<String>) - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Sets the topics to subscribe to, if many.

start() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Starts streamer.

stop() - Method in class org.apache.ignite.stream.mqtt.MqttStreamer

Stops streamer.

C D G I M O S