org.apache.storm.mqtt.common

Class MqttPublisher

java.lang.Object

org.apache.storm.mqtt.common.MqttPublisher

public class MqttPublisher
extends Object

Constructor Summary

Constructors

Constructor and Description
MqttPublisher(MqttOptions options)
MqttPublisher(MqttOptions options, boolean retain)
MqttPublisher(MqttOptions options, KeyStoreLoader keyStoreLoader, boolean retain)

Method Summary

Modifier and Type	Method and Description
void	connectMqtt(String clientId)
void	publish(MqttMessage message)

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttPublisher

public MqttPublisher(MqttOptions options)

MqttPublisher

public MqttPublisher(MqttOptions options,
                     boolean retain)

MqttPublisher

public MqttPublisher(MqttOptions options,
                     KeyStoreLoader keyStoreLoader,
                     boolean retain)

Method Detail

publish

public void publish(MqttMessage message)
             throws Exception

Throws:

Exception

connectMqtt

public void connectMqtt(String clientId)
                 throws Exception

Throws:

Exception