org.apache.storm.mqtt.examples

Class MqttBrokerPublisher

java.lang.Object

org.apache.storm.mqtt.examples.MqttBrokerPublisher

public final class MqttBrokerPublisher
extends Object

A MQTT example using a Storm topology.

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args) The main method.
static void	publish() Publishes topics on connection.
static void	startBroker() Initializes broker and starts it.
static void	startPublisher() Initializes connection.

Methods inherited from class java.lang.Object

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

Method Detail

startBroker

public static void startBroker()
                        throws Exception

Initializes broker and starts it.

Throws:

Exception - if an exception during adding a connector occurs

startPublisher

public static void startPublisher()
                           throws Exception

Initializes connection.

Throws:

Exception - if an exception during connecting to connector occurs

publish

public static void publish()
                    throws Exception

Publishes topics on connection.

Throws:

Exception - if an exception during publishing occurs

main

public static void main(String[] args)
                 throws Exception

The main method.

Parameters:

args - the command line arguments

Throws:

Exception - if an exception during connections or transmission occurs