Index (IIP-Ecosphere MQTT v3 transport spring binder 0.8.1-SNAPSHOT API)

A C D F G I K L M O P Q S T U W
All Classes and Interfaces|All Packages

A

actionTimeout - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration
autoClientId - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration

C

callback - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient
Callback() - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient.Callback
Callback() - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageProducer.Callback
callbacks - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient.Callback
client - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient
client - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinder
client - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner
client - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageProducer
clientId - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration
configuration - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient
connectionLost(Throwable) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient.Callback
createClient(MqttConfiguration) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Creates the client based on a given MQTT client configuration.
createConsumerEndpoint(ConsumerDestination, String, ConsumerProperties) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinder
createProducerMessageHandler(ProducerDestination, ProducerProperties, MessageChannel) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinder

D

de.iip_ecosphere.platform.transport.spring.binder.mqttv3 - package de.iip_ecosphere.platform.transport.spring.binder.mqttv3: Implements a Spring Cloud Stream binder for MQTT v3.
deliveryComplete(IMqttDeliveryToken) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient.Callback
destination - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner.MqttMessageDestination
destination - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageProducer
doStart() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageProducer
doStop() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageProducer

F

filteredTopics - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration

G

getActionTimeout() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns the action timeout to wait for the broker to complete an action.
getAutoClientId() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns whether making the client ID unique is enabled.
getBrokerString() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns the broker connection string consisting of MqttConfiguration.getSchema(), BasicConfiguration.getHost() and BasicConfiguration.getPort().
getClientId() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns the client identification.
getConfiguration() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Returns the actual configuration.
getFilteredTopics() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns all filtered topics.
getKeepAlive() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns the keep-alive time between heartbeats.
getLastInstance() - Static method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Returns the last instance created for this class.
getName() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner.MqttMessageDestination
getNameForPartition(int) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner.MqttMessageDestination
getQos() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns the QoS level for sending.
getSchema() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns the connection schema.

I

isFilteredTopic(String) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Returns whether topic is a filtered topic, i.e., we shall not subscribe to this topic.

K

keepAlive - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration

L

lastInstance - Static variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient
LOGGER - Static variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient

M

messageArrived(String, MqttMessage) - Method in interface de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient.ArrivedCallback: This method is called when a message arrives from the server.
messageArrived(String, MqttMessage) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient.Callback
messageArrived(String, MqttMessage) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageProducer.Callback
mqttClient() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderConfiguration: Returns the client instance.
MqttClient - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: A MQTT client for a single binder instance.
MqttClient() - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Creates and registers an instance.
MqttClient.ArrivedCallback - Interface in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: Called when a message for a topic arrives.
MqttClient.Callback - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: The internal MQTT reception callback.
MqttConfiguration - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: Represents the configuration options of a MQTT v3 client.
MqttConfiguration() - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration
MqttMessageDestination(String) - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner.MqttMessageDestination: Implements a message destination.
mqttTransportParameter(ApplicationContext, MqttConfiguration) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderConfiguration: Provides a transport parameter instance configured through the binder configuration.
mqttv3Binder(MqttV3MessageBinderProvisioner, MqttClient) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderConfiguration: Returns the message binder.
mqttv3BinderProvisioner(MqttClient) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderConfiguration: Returns the binder provisioner.
MqttV3MessageBinder - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: A MQTT v3 message binder turning messages to be sent into MQTT messages.
MqttV3MessageBinder(String[], MqttV3MessageBinderProvisioner, MqttClient) - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinder: Creates a message binder instance.
MqttV3MessageBinderConfiguration - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: Represents the MQTT v3 message binder plugin.
MqttV3MessageBinderConfiguration() - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderConfiguration
MqttV3MessageBinderProvisioner - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: Provisions consumer and producer properties.
MqttV3MessageBinderProvisioner(MqttClient) - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner: Creates a provisioner instance.
MqttV3MessageBinderProvisioner.MqttMessageDestination - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: Implements a message destination for MQTT v3.
MqttV3MessageProducer - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: Implements a MQTT v3 message producer.
MqttV3MessageProducer(ConsumerDestination, MqttClient) - Constructor for class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageProducer: Creates a message producer instance.
MqttV3MessageProducer.Callback - Class in de.iip_ecosphere.platform.transport.spring.binder.mqttv3: The topic-specific reception callback.

O

options - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner

P

provisionConsumerDestination(String, String, ConsumerProperties) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner
provisionProducerDestination(String, ProducerProperties) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttV3MessageBinderProvisioner

Q

qos - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient
qos - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration

S

schema - Variable in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration
send(String, byte[]) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Sends payload to topic.
setActionTimeout(int) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Changes the action timeout to wait for the broker to complete an action.
setAutoClientId(boolean) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Changes whether the client identification is expected to be unique or shall be made unique upon first connect.
setClientId(String) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Changes the client identification.
setFilteredTopics(List<String>) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Changes all filtered topics.
setKeepAlive(int) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Changes the keep-alive time between heartbeats.
setQos(String) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Defines the QoS level.
setSchema(String) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Changes the connection schema.
stopClient() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Stops the client.
subscribeTo(String, MqttClient.ArrivedCallback) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Subscribes to topic if topic is not blacklisted by MqttConfiguration.isFilteredTopic(String).

T

toTransportParameter() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration: Turns the actual configuration into a TransportParameter instance.

U

unsubscribeFrom(String) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Unsubscribes from topic if topic is not blacklisted by MqttConfiguration.isFilteredTopic(String).

W

waitForCompletion(IMqttToken) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient: Waits for completion until the token is processed.

A C D F G I K L M O P Q S T U W
All Classes and Interfaces|All Packages