Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2597#discussion_r177716911
--- Diff:
examples/storm-mqtt-examples/src/main/java/org/apache/storm/mqtt/examples/MqttBrokerPublisher.java
---
@@ -15,35 +15,62 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.apache.storm.mqtt.examples;
+import java.util.Random;
import org.apache.activemq.broker.BrokerService;
import org.apache.storm.mqtt.MqttLogger;
import org.fusesource.mqtt.client.BlockingConnection;
import org.fusesource.mqtt.client.MQTT;
import org.fusesource.mqtt.client.QoS;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.util.Random;
-
-public class MqttBrokerPublisher {
- private static final Logger LOG =
LoggerFactory.getLogger(MqttBrokerPublisher.class);
-
+/**
+ * A MQTT example using a Storm topology.
+ */
+public final class MqttBrokerPublisher {
+ /**
+ * The logger.
+ */
+ private static final Logger LOG = LoggerFactory.getLogger(
+ MqttBrokerPublisher.class);
+ /**
+ * The broker.
+ */
private static BrokerService broker;
-
+ /**
+ * The connection reference.
+ */
private static BlockingConnection connection;
+ /**
+ * The maximum temperature.
+ */
+ private static final int TEMPERATUR_MAX = 100;
--- End diff --
TEMPERATUR_MAX -> TEMPERATURE_MAX
---
