content: /*
   * Licensed to the Apache Software Foundation (ASF) under one or more
   * contributor license agreements.  See the NOTICE file distributed with
   * this work for additional information regarding copyright ownership.
   * The ASF licenses this file to You under the Apache License, Version 2.0
   * (the "License"); you may not use this file except in compliance with
   * the License.  You may obtain a copy of the License at
   *
   *    http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  
  package org.apache.spark.streaming.mqtt;
  
  import org.apache.spark.storage.StorageLevel;
  import org.apache.spark.streaming.LocalJavaStreamingContext;
  import org.apache.spark.streaming.api.java.JavaReceiverInputDStream;
  import org.junit.Test;
  
  import scala.Tuple2;
  
  public class JavaMQTTStreamSuite extends LocalJavaStreamingContext {
    @Test
    public void testMQTTStream() {
      String brokerUrl = "abc";
      String topic = "def";
      String[] topics = {"def1","def2"};
  
      // tests the API, does not actually test data receiving
      JavaReceiverInputDStream<String> test1 = MQTTUtils.createStream(ssc, brokerUrl, topic);
      JavaReceiverInputDStream<String> test2 = MQTTUtils.createStream(ssc, brokerUrl, topic,
        StorageLevel.MEMORY_AND_DISK_SER_2());
      JavaReceiverInputDStream<String> test3 = MQTTUtils.createStream(ssc, brokerUrl, topic,
        StorageLevel.MEMORY_AND_DISK_SER_2(), "testid", "user", "password", true, 1, 10, 30, 3);
      JavaReceiverInputDStream<String> test4 = MQTTUtils.createStream(ssc, brokerUrl, topic,
        "testid", "user", "password", true, 1, 10, 30, 3);
      JavaReceiverInputDStream<String> test5 = MQTTUtils.createStream(ssc, brokerUrl, topic,
        "testid", "user", "password", true);
      JavaReceiverInputDStream<Tuple2<String, String>> test6 = MQTTUtils.createPairedStream(ssc,
        brokerUrl, topics);
      JavaReceiverInputDStream<Tuple2<String, String>> test7 = MQTTUtils.createPairedStream(ssc,
        brokerUrl, topics, StorageLevel.MEMORY_AND_DISK_SER_2());
      JavaReceiverInputDStream<Tuple2<String, String>> test8 = MQTTUtils.createPairedStream(ssc,
        brokerUrl, topics, StorageLevel.MEMORY_AND_DISK_SER_2(), "testid", "user",
        "password", true, 1, 10, 30, 3);
      JavaReceiverInputDStream<Tuple2<String, String>> test9 = MQTTUtils.createPairedStream(ssc,
        brokerUrl, topics, "testid", "user", "password", true, 1,
        10, 30, 3);
      JavaReceiverInputDStream<Tuple2<String, String>> test10 = MQTTUtils.createPairedStream(ssc,
        brokerUrl, topics, "testid", "user", "password", true);
      JavaReceiverInputDStream<Tuple2<String, byte[]>> test11 =
              MQTTUtils.createPairedByteArrayStream(ssc, brokerUrl, topics);
      JavaReceiverInputDStream<Tuple2<String, byte[]>> test12 =
              MQTTUtils.createPairedByteArrayStream(ssc, brokerUrl, topics,
              StorageLevel.MEMORY_AND_DISK_SER_2());
      JavaReceiverInputDStream<Tuple2<String, byte[]>> test13 =
              MQTTUtils.createPairedByteArrayStream(ssc, brokerUrl, topics,
              StorageLevel.MEMORY_AND_DISK_SER_2(), "testid", "user",
              "password", true, 1, 10, 30, 3);
      JavaReceiverInputDStream<Tuple2<String, byte[]>> test14 =
              MQTTUtils.createPairedByteArrayStream(ssc, brokerUrl, topics,
              "testid", "user", "password", true,
               1, 10, 30, 3);
      JavaReceiverInputDStream<Tuple2<String, byte[]>> test15 =
              MQTTUtils.createPairedByteArrayStream(ssc, brokerUrl, topics, "testid",
              "user", "password", true);
  
    }
  }
  