org.apache.nifi.processors.mqtt

Class TestPublishMQTT.UnitTestablePublishMqtt

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor

org.apache.nifi.processors.mqtt.PublishMQTT

org.apache.nifi.processors.mqtt.TestPublishMQTT.UnitTestablePublishMqtt

All Implemented Interfaces:

ConfigurableComponent, Processor

Enclosing class:

TestPublishMQTT

public class TestPublishMQTT.UnitTestablePublishMqtt
extends PublishMQTT

Field Summary

Fields inherited from class org.apache.nifi.processors.mqtt.PublishMQTT

PROP_QOS, PROP_RETAIN, PROP_TOPIC, REL_FAILURE, REL_SUCCESS

Fields inherited from class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor

broker, BROKER_VALIDATOR, clientID, connOpts, logger, mqttClient, mqttClientConnectLock, persistence, processSessionFactory, PROP_BROKER_URI, PROP_CLEAN_SESSION, PROP_CLIENTID, PROP_CONN_TIMEOUT, PROP_KEEP_ALIVE_INTERVAL, PROP_LAST_WILL_MESSAGE, PROP_LAST_WILL_QOS, PROP_LAST_WILL_RETAIN, PROP_LAST_WILL_TOPIC, PROP_MQTT_VERSION, PROP_PASSWORD, PROP_SSL_CONTEXT_SERVICE, PROP_USERNAME, QOS_VALIDATOR, RETAIN_VALIDATOR

Constructor Summary

Constructors

Constructor and Description
UnitTestablePublishMqtt()

Method Summary

Modifier and Type	Method and Description
org.eclipse.paho.client.mqttv3.IMqttClient	getMqttClient(java.lang.String broker, java.lang.String clientID, org.eclipse.paho.client.mqttv3.persist.MemoryPersistence persistence)

Methods inherited from class org.apache.nifi.processors.mqtt.PublishMQTT

getRelationships, getSupportedPropertyDescriptors, init, onScheduled, onStop, onTrigger

Methods inherited from class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor

buildClient, customValidate, getAbstractPropertyDescriptors, onTrigger, setAndConnectClient, transformSSLContextService

Methods inherited from class org.apache.nifi.processor.AbstractSessionFactoryProcessor

getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, initialize, isConfigurationRestored, isScheduled, toString, updateConfiguredRestoredTrue, updateScheduledFalse, updateScheduledTrue

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, hashCode, onPropertyModified, validate

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Constructor Detail

UnitTestablePublishMqtt

public UnitTestablePublishMqtt()

Method Detail

getMqttClient

public org.eclipse.paho.client.mqttv3.IMqttClient getMqttClient(java.lang.String broker,
                                                                java.lang.String clientID,
                                                                org.eclipse.paho.client.mqttv3.persist.MemoryPersistence persistence)
                                                         throws org.eclipse.paho.client.mqttv3.MqttException

Overrides:

getMqttClient in class AbstractMQTTProcessor

Throws:

org.eclipse.paho.client.mqttv3.MqttException