org.apache.nifi.processors.mqtt.integration

Class TestConsumeMQTT

java.lang.Object

org.apache.nifi.processors.mqtt.common.TestConsumeMqttCommon

org.apache.nifi.processors.mqtt.integration.TestConsumeMQTT

public class TestConsumeMQTT
extends TestConsumeMqttCommon

Field Summary

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

broker, MQTT_server, PUBLISH_WAIT_MS, testRunner

Constructor Summary

Constructors

Constructor and Description
TestConsumeMQTT()

Method Summary

Modifier and Type	Method and Description
void	init()
void	internalPublish(io.moquette.proto.messages.PublishMessage publishMessage)
void	tearDown()
void	testRetainedQoS2()

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

getMqttQueue, reconnect, testLastWillConfig, testOnStoppedFinish, testQoS0, testQoS1, testQoS1NotCleanSession, testQoS2, testQoS2NotCleanSession, testResizeBuffer, transferQueue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestConsumeMQTT

public TestConsumeMQTT()

Method Detail

init

public void init()
          throws java.io.IOException

Throws:

java.io.IOException

tearDown

public void tearDown()
              throws java.lang.Exception

Throws:

java.lang.Exception

testRetainedQoS2

public void testRetainedQoS2()
                      throws java.lang.Exception

Throws:

java.lang.Exception

internalPublish

public void internalPublish(io.moquette.proto.messages.PublishMessage publishMessage)

Specified by:

internalPublish in class TestConsumeMqttCommon