Index
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()andBasicConfiguration.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
topicis 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
payloadtotopic. - 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
T
- toTransportParameter() - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttConfiguration
-
Turns the actual configuration into a
TransportParameterinstance.
U
- unsubscribeFrom(String) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient
W
- waitForCompletion(IMqttToken) - Method in class de.iip_ecosphere.platform.transport.spring.binder.mqttv3.MqttClient
-
Waits for completion until the
tokenis processed.
All Classes and Interfaces|All Packages