You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by qu...@apache.org on 2016/07/26 21:33:00 UTC
[30/51] [partial] incubator-quarks-website git commit: [QUARKS-233]
Rename Quarks to Edgent * text references * image references * placeholder
logos * Javadoc
http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/05ad5e88/site/javadoc/lastest/quarks/connectors/kafka/package-tree.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/package-tree.html b/site/javadoc/lastest/quarks/connectors/kafka/package-tree.html
deleted file mode 100644
index 94b81bb..0000000
--- a/site/javadoc/lastest/quarks/connectors/kafka/package-tree.html
+++ /dev/null
@@ -1,149 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_71) on Tue May 17 00:28:46 UTC 2016 -->
-<title>quarks.connectors.kafka Class Hierarchy (Quarks v0.4.0)</title>
-<meta name="date" content="2016-05-17">
-<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
- try {
- if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="quarks.connectors.kafka Class Hierarchy (Quarks v0.4.0)";
- }
- }
- catch(err) {
- }
-//-->
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li>Class</li>
-<li>Use</li>
-<li class="navBarCell1Rev">Tree</li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../quarks/connectors/jdbc/package-tree.html">Prev</a></li>
-<li><a href="../../../quarks/connectors/mqtt/package-tree.html">Next</a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/kafka/package-tree.html" target="_top">Frames</a></li>
-<li><a href="package-tree.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_top");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<a name="skip.navbar.top">
-<!-- -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<div class="header">
-<h1 class="title">Hierarchy For Package quarks.connectors.kafka</h1>
-<span class="packageHierarchyLabel">Package Hierarchies:</span>
-<ul class="horizontal">
-<li><a href="../../../overview-tree.html">All Packages</a></li>
-</ul>
-</div>
-<div class="contentContainer">
-<h2 title="Class Hierarchy">Class Hierarchy</h2>
-<ul>
-<li type="circle">java.lang.Object
-<ul>
-<li type="circle">quarks.connectors.kafka.<a href="../../../quarks/connectors/kafka/KafkaConsumer.html" title="class in quarks.connectors.kafka"><span class="typeNameLink">KafkaConsumer</span></a></li>
-<li type="circle">quarks.connectors.kafka.<a href="../../../quarks/connectors/kafka/KafkaProducer.html" title="class in quarks.connectors.kafka"><span class="typeNameLink">KafkaProducer</span></a></li>
-</ul>
-</li>
-</ul>
-<h2 title="Interface Hierarchy">Interface Hierarchy</h2>
-<ul>
-<li type="circle">quarks.connectors.kafka.<a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">KafkaConsumer.ConsumerRecord</span></a><K,V>
-<ul>
-<li type="circle">quarks.connectors.kafka.<a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">KafkaConsumer.ByteConsumerRecord</span></a></li>
-<li type="circle">quarks.connectors.kafka.<a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">KafkaConsumer.StringConsumerRecord</span></a></li>
-</ul>
-</li>
-</ul>
-</div>
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li>Class</li>
-<li>Use</li>
-<li class="navBarCell1Rev">Tree</li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-<div class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../quarks/connectors/jdbc/package-tree.html">Prev</a></li>
-<li><a href="../../../quarks/connectors/mqtt/package-tree.html">Next</a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/kafka/package-tree.html" target="_top">Frames</a></li>
-<li><a href="package-tree.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_bottom");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-<p class="legalCopy"><small>Copyright © 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/05ad5e88/site/javadoc/lastest/quarks/connectors/kafka/package-use.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/package-use.html b/site/javadoc/lastest/quarks/connectors/kafka/package-use.html
deleted file mode 100644
index d04d78a..0000000
--- a/site/javadoc/lastest/quarks/connectors/kafka/package-use.html
+++ /dev/null
@@ -1,173 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_71) on Tue May 17 00:28:47 UTC 2016 -->
-<title>Uses of Package quarks.connectors.kafka (Quarks v0.4.0)</title>
-<meta name="date" content="2016-05-17">
-<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
- try {
- if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Uses of Package quarks.connectors.kafka (Quarks v0.4.0)";
- }
- }
- catch(err) {
- }
-//-->
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li>Class</li>
-<li class="navBarCell1Rev">Use</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li>Prev</li>
-<li>Next</li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/kafka/package-use.html" target="_top">Frames</a></li>
-<li><a href="package-use.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_top");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<a name="skip.navbar.top">
-<!-- -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<div class="header">
-<h1 title="Uses of Package quarks.connectors.kafka" class="title">Uses of Package<br>quarks.connectors.kafka</h1>
-</div>
-<div class="contentContainer">
-<ul class="blockList">
-<li class="blockList">
-<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing packages, and an explanation">
-<caption><span>Packages that use <a href="../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a></span><span class="tabEnd"> </span></caption>
-<tr>
-<th class="colFirst" scope="col">Package</th>
-<th class="colLast" scope="col">Description</th>
-</tr>
-<tbody>
-<tr class="altColor">
-<td class="colFirst"><a href="#quarks.connectors.kafka">quarks.connectors.kafka</a></td>
-<td class="colLast">
-<div class="block">Apache Kafka enterprise messing hub stream connector.</div>
-</td>
-</tr>
-</tbody>
-</table>
-</li>
-<li class="blockList"><a name="quarks.connectors.kafka">
-<!-- -->
-</a>
-<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing classes, and an explanation">
-<caption><span>Classes in <a href="../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a> used by <a href="../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a></span><span class="tabEnd"> </span></caption>
-<tr>
-<th class="colOne" scope="col">Class and Description</th>
-</tr>
-<tbody>
-<tr class="altColor">
-<td class="colOne"><a href="../../../quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html#quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a>
-<div class="block">A Kafka record with byte[] typed key and value members</div>
-</td>
-</tr>
-<tr class="rowColor">
-<td class="colOne"><a href="../../../quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html#quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a>
-<div class="block">A received Kafka record</div>
-</td>
-</tr>
-<tr class="altColor">
-<td class="colOne"><a href="../../../quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html#quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a>
-<div class="block">A Kafka record with String typed key and value members</div>
-</td>
-</tr>
-</tbody>
-</table>
-</li>
-</ul>
-</div>
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li>Class</li>
-<li class="navBarCell1Rev">Use</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-<div class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li>Prev</li>
-<li>Next</li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/kafka/package-use.html" target="_top">Frames</a></li>
-<li><a href="package-use.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_bottom");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-<p class="legalCopy"><small>Copyright © 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/05ad5e88/site/javadoc/lastest/quarks/connectors/mqtt/MqttConfig.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/mqtt/MqttConfig.html b/site/javadoc/lastest/quarks/connectors/mqtt/MqttConfig.html
deleted file mode 100644
index 6eed7ee..0000000
--- a/site/javadoc/lastest/quarks/connectors/mqtt/MqttConfig.html
+++ /dev/null
@@ -1,1125 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_71) on Tue May 17 00:28:45 UTC 2016 -->
-<title>MqttConfig (Quarks v0.4.0)</title>
-<meta name="date" content="2016-05-17">
-<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
- try {
- if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MqttConfig (Quarks v0.4.0)";
- }
- }
- catch(err) {
- }
-//-->
-var methods = {"i0":9,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10};
-var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="class-use/MqttConfig.html">Use</a></li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li>Prev Class</li>
-<li><a href="../../../quarks/connectors/mqtt/MqttStreams.html" title="class in quarks.connectors.mqtt"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/mqtt/MqttConfig.html" target="_top">Frames</a></li>
-<li><a href="MqttConfig.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_top");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!-- -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">quarks.connectors.mqtt</div>
-<h2 title="Class MqttConfig" class="title">Class MqttConfig</h2>
-</div>
-<div class="contentContainer">
-<ul class="inheritance">
-<li>java.lang.Object</li>
-<li>
-<ul class="inheritance">
-<li>quarks.connectors.mqtt.MqttConfig</li>
-</ul>
-</li>
-</ul>
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<hr>
-<br>
-<pre>public class <span class="typeNameLabel">MqttConfig</span>
-extends java.lang.Object</pre>
-<div class="block">MQTT broker connector configuration.</div>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ======== CONSTRUCTOR SUMMARY ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.summary">
-<!-- -->
-</a>
-<h3>Constructor Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
-<caption><span>Constructors</span><span class="tabEnd"> </span></caption>
-<tr>
-<th class="colOne" scope="col">Constructor and Description</th>
-</tr>
-<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#MqttConfig--">MqttConfig</a></span>()</code>
-<div class="block">Create a new configuration.</div>
-</td>
-</tr>
-<tr class="rowColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#MqttConfig-java.lang.String-java.lang.String-">MqttConfig</a></span>(java.lang.String serverURL,
- java.lang.String clientId)</code>
-<div class="block">Create a new configuration.</div>
-</td>
-</tr>
-</table>
-</li>
-</ul>
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!-- -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t1" class="tableTab"><span><a href="javascript:show(1);">Static Methods</a></span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code>static <a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt">MqttConfig</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#fromProperties-java.util.Properties-">fromProperties</a></span>(java.util.Properties properties)</code>
-<div class="block">Create a new configuration from <code>Properties</code>.</div>
-</td>
-</tr>
-<tr id="i1" class="rowColor">
-<td class="colFirst"><code>long</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getActionTimeToWaitMillis--">getActionTimeToWaitMillis</a></span>()</code>
-<div class="block">Get the maximum time to wait for an action (e.g., publish message) to complete.</div>
-</td>
-</tr>
-<tr id="i2" class="altColor">
-<td class="colFirst"><code>java.lang.String</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getClientId--">getClientId</a></span>()</code>
-<div class="block">Get the connection Client Id.</div>
-</td>
-</tr>
-<tr id="i3" class="rowColor">
-<td class="colFirst"><code>int</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getConnectionTimeout--">getConnectionTimeout</a></span>()</code>
-<div class="block">Get the connection timeout.</div>
-</td>
-</tr>
-<tr id="i4" class="altColor">
-<td class="colFirst"><code>int</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getIdleTimeout--">getIdleTimeout</a></span>()</code>
-<div class="block">Get the idle connection timeout.</div>
-</td>
-</tr>
-<tr id="i5" class="rowColor">
-<td class="colFirst"><code>int</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getKeepAliveInterval--">getKeepAliveInterval</a></span>()</code>
-<div class="block">Get the connection Keep alive interval.</div>
-</td>
-</tr>
-<tr id="i6" class="altColor">
-<td class="colFirst"><code>java.lang.String</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getKeyStore--">getKeyStore</a></span>()</code>
-<div class="block">Get the SSL trust store path.</div>
-</td>
-</tr>
-<tr id="i7" class="rowColor">
-<td class="colFirst"><code>char[]</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getKeyStorePassword--">getKeyStorePassword</a></span>()</code>
-<div class="block">Get the SSL key store path password.</div>
-</td>
-</tr>
-<tr id="i8" class="altColor">
-<td class="colFirst"><code>char[]</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getPassword--">getPassword</a></span>()</code>
-<div class="block">Get the the password to use for authentication with the server.</div>
-</td>
-</tr>
-<tr id="i9" class="rowColor">
-<td class="colFirst"><code>org.eclipse.paho.client.mqttv3.MqttClientPersistence</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getPersistence--">getPersistence</a></span>()</code>
-<div class="block">Get the QoS 1 and 2 in-flight message persistence handler.</div>
-</td>
-</tr>
-<tr id="i10" class="altColor">
-<td class="colFirst"><code>java.lang.String[]</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getServerURLs--">getServerURLs</a></span>()</code>
-<div class="block">Get the MQTT Server URLs</div>
-</td>
-</tr>
-<tr id="i11" class="rowColor">
-<td class="colFirst"><code>int</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getSubscriberIdleReconnectInterval--">getSubscriberIdleReconnectInterval</a></span>()</code>
-<div class="block">Get the subscriber idle reconnect interval.</div>
-</td>
-</tr>
-<tr id="i12" class="altColor">
-<td class="colFirst"><code>java.lang.String</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getTrustStore--">getTrustStore</a></span>()</code>
-<div class="block">Get the SSL trust store path.</div>
-</td>
-</tr>
-<tr id="i13" class="rowColor">
-<td class="colFirst"><code>char[]</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getTrustStorePassword--">getTrustStorePassword</a></span>()</code>
-<div class="block">Get the SSL trust store path password.</div>
-</td>
-</tr>
-<tr id="i14" class="altColor">
-<td class="colFirst"><code>java.lang.String</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getUserName--">getUserName</a></span>()</code>
-<div class="block">Get the username to use for authentication with the server.</div>
-</td>
-</tr>
-<tr id="i15" class="rowColor">
-<td class="colFirst"><code>java.lang.String</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getWillDestination--">getWillDestination</a></span>()</code>
-<div class="block">Get a Last Will and Testament message's destination topic.</div>
-</td>
-</tr>
-<tr id="i16" class="altColor">
-<td class="colFirst"><code>byte[]</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getWillPayload--">getWillPayload</a></span>()</code>
-<div class="block">Get a Last Will and Testament message's payload.</div>
-</td>
-</tr>
-<tr id="i17" class="rowColor">
-<td class="colFirst"><code>int</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getWillQOS--">getWillQOS</a></span>()</code>
-<div class="block">Get a Last Will and Testament message's QOS.</div>
-</td>
-</tr>
-<tr id="i18" class="altColor">
-<td class="colFirst"><code>boolean</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#getWillRetained--">getWillRetained</a></span>()</code>
-<div class="block">Get a Last Will and Testament message's "retained" setting.</div>
-</td>
-</tr>
-<tr id="i19" class="rowColor">
-<td class="colFirst"><code>boolean</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#isCleanSession--">isCleanSession</a></span>()</code>
-<div class="block">Get the clean session setting.</div>
-</td>
-</tr>
-<tr id="i20" class="altColor">
-<td class="colFirst"><code>java.lang.Object</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#options--">options</a></span>()</code>
-<div class="block">INTERNAL USE ONLY.</div>
-</td>
-</tr>
-<tr id="i21" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setActionTimeToWaitMillis-long-">setActionTimeToWaitMillis</a></span>(long actionTimeToWaitMillis)</code>
-<div class="block">Maximum time to wait for an action (e.g., publish message) to complete.</div>
-</td>
-</tr>
-<tr id="i22" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setCleanSession-boolean-">setCleanSession</a></span>(boolean cleanSession)</code>
-<div class="block">Clean Session.</div>
-</td>
-</tr>
-<tr id="i23" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setClientId-java.lang.String-">setClientId</a></span>(java.lang.String clientId)</code>
-<div class="block">Connection Client Id.</div>
-</td>
-</tr>
-<tr id="i24" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setConnectionTimeout-int-">setConnectionTimeout</a></span>(int connectionTimeoutSec)</code>
-<div class="block">Connection timeout.</div>
-</td>
-</tr>
-<tr id="i25" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setIdleTimeout-int-">setIdleTimeout</a></span>(int idleTimeoutSec)</code>
-<div class="block">Idle connection timeout.</div>
-</td>
-</tr>
-<tr id="i26" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setKeepAliveInterval-int-">setKeepAliveInterval</a></span>(int keepAliveSec)</code>
-<div class="block">Connection Keep alive.</div>
-</td>
-</tr>
-<tr id="i27" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setKeyStore-java.lang.String-">setKeyStore</a></span>(java.lang.String path)</code>
-<div class="block">Set the SSL key store path.</div>
-</td>
-</tr>
-<tr id="i28" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setKeyStorePassword-char:A-">setKeyStorePassword</a></span>(char[] password)</code>
-<div class="block">Set the SSL key store password.</div>
-</td>
-</tr>
-<tr id="i29" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setPassword-char:A-">setPassword</a></span>(char[] password)</code>
-<div class="block">Set the password to use for authentication with the server.</div>
-</td>
-</tr>
-<tr id="i30" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setPersistence-org.eclipse.paho.client.mqttv3.MqttClientPersistence-">setPersistence</a></span>(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)</code>
-<div class="block">QoS 1 and 2 in-flight message persistence.</div>
-</td>
-</tr>
-<tr id="i31" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setServerURLs-java.lang.String:A-">setServerURLs</a></span>(java.lang.String[] serverUrls)</code>
-<div class="block">MQTT Server URLs</div>
-</td>
-</tr>
-<tr id="i32" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setSubscriberIdleReconnectInterval-int-">setSubscriberIdleReconnectInterval</a></span>(int seconds)</code>
-<div class="block">Subscriber idle reconnect interval.</div>
-</td>
-</tr>
-<tr id="i33" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setTrustStore-java.lang.String-">setTrustStore</a></span>(java.lang.String path)</code>
-<div class="block">Set the SSL trust store path.</div>
-</td>
-</tr>
-<tr id="i34" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setTrustStorePassword-char:A-">setTrustStorePassword</a></span>(char[] password)</code>
-<div class="block">Set the SSL trust store password.</div>
-</td>
-</tr>
-<tr id="i35" class="rowColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setUserName-java.lang.String-">setUserName</a></span>(java.lang.String userName)</code>
-<div class="block">Set the username to use for authentication with the server.</div>
-</td>
-</tr>
-<tr id="i36" class="altColor">
-<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setWill-java.lang.String-byte:A-int-boolean-">setWill</a></span>(java.lang.String topic,
- byte[] payload,
- int qos,
- boolean retained)</code>
-<div class="block">Last Will and Testament.</div>
-</td>
-</tr>
-</table>
-<ul class="blockList">
-<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
-<!-- -->
-</a>
-<h3>Methods inherited from class java.lang.Object</h3>
-<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========= CONSTRUCTOR DETAIL ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.detail">
-<!-- -->
-</a>
-<h3>Constructor Detail</h3>
-<a name="MqttConfig--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>MqttConfig</h4>
-<pre>public MqttConfig()</pre>
-<div class="block">Create a new configuration.</div>
-</li>
-</ul>
-<a name="MqttConfig-java.lang.String-java.lang.String-">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>MqttConfig</h4>
-<pre>public MqttConfig(java.lang.String serverURL,
- java.lang.String clientId)</pre>
-<div class="block">Create a new configuration.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>serverURL</code> - the MQTT broker's URL</dd>
-<dd><code>clientId</code> - the MQTT client's id. Auto-generated if null.</dd>
-</dl>
-</li>
-</ul>
-</li>
-</ul>
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!-- -->
-</a>
-<h3>Method Detail</h3>
-<a name="fromProperties-java.util.Properties-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>fromProperties</h4>
-<pre>public static <a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt">MqttConfig</a> fromProperties(java.util.Properties properties)</pre>
-<div class="block">Create a new configuration from <code>Properties</code>.
- <p>
- There is a property corresponding to each <code>MqttConfig.set<name>()</code>
- method. Unless otherwise stated, the property's value is a string
- of the corresponding method's argument type.
- Properties not specified yield a configuration value as
- described by and their corresponding <code>set<name>()</code>.
- <p>
- Properties other than those noted are ignored.
-
- <h3>MQTT connector properties</h3>
- <ul>
- <li>mqtt.actionTimeToWaitMillis</li>
- <li>mqtt.cleanSession</li>
- <li>mqtt.clientId</li>
- <li>mqtt.connectionTimeoutSec</li>
- <li>mqtt.idleTimeoutSec</li>
- <li>mqtt.keepAliveSec</li>
- <li>mqtt.keyStore - optional. Only used with "ssl:" serverURL when the
- server is configured for client auth.
- Path to key store file in JKS format.
- The first key in the store is used. The key must have the same
- password as the store if any.
- If not set, the standard JRE and javax.net.ssl system properties
- control the SSL behavior.</li>
- <li>mqtt.keyStorePassword - required if mqtt.keyStore is set.</li>
- <li>mqtt.password</li>
- <li>mqtt.persistence</li>
- <li>mqtt.serverURLs - csv list of MQTT URLs of the form:
- <code>tcp://<host>:<port></code> or
- <code>ssl://<host>:<port></code>
- </li>
- <li>mqtt.subscriberIdleReconnectIntervalSec</li>
- <li>mqtt.trustStore - optional. Only used with "ssl:" serverURL.
- Path to trust store file in JKS format.
- If not set, the standard JRE and javax.net.ssl system properties
- control the SSL behavior.
- Generally not required if server has a CA-signed certificate.</li>
- <li>mqtt.trustStorePassword - required if mqtt.trustStore is set</li>
- <li>mqtt.userName</li>
- <li>mqtt.will - JSON for with the following properties:
- <ul>
- <li>topic - string</li>
- <li>payload - string for byte[] in UTF8</li>
- <li>qos - integer</li>
- <li>retained - boolean</li>
- </ul>
- </li>
- </ul></div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>properties</code> - properties specifying the configuration.</dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the configuration</dd>
-<dt><span class="throwsLabel">Throws:</span></dt>
-<dd><code>java.lang.IllegalArgumentException</code> - for illegal values</dd>
-</dl>
-</li>
-</ul>
-<a name="getClientId--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getClientId</h4>
-<pre>public java.lang.String getClientId()</pre>
-<div class="block">Get the connection Client Id.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getActionTimeToWaitMillis--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getActionTimeToWaitMillis</h4>
-<pre>public long getActionTimeToWaitMillis()</pre>
-<div class="block">Get the maximum time to wait for an action (e.g., publish message) to complete.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getPersistence--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getPersistence</h4>
-<pre>public org.eclipse.paho.client.mqttv3.MqttClientPersistence getPersistence()</pre>
-<div class="block">Get the QoS 1 and 2 in-flight message persistence handler.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getConnectionTimeout--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getConnectionTimeout</h4>
-<pre>public int getConnectionTimeout()</pre>
-<div class="block">Get the connection timeout.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getIdleTimeout--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getIdleTimeout</h4>
-<pre>public int getIdleTimeout()</pre>
-<div class="block">Get the idle connection timeout.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getSubscriberIdleReconnectInterval--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getSubscriberIdleReconnectInterval</h4>
-<pre>public int getSubscriberIdleReconnectInterval()</pre>
-<div class="block">Get the subscriber idle reconnect interval.</div>
-</li>
-</ul>
-<a name="getKeepAliveInterval--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getKeepAliveInterval</h4>
-<pre>public int getKeepAliveInterval()</pre>
-<div class="block">Get the connection Keep alive interval.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getServerURLs--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getServerURLs</h4>
-<pre>public java.lang.String[] getServerURLs()</pre>
-<div class="block">Get the MQTT Server URLs</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getWillDestination--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getWillDestination</h4>
-<pre>public java.lang.String getWillDestination()</pre>
-<div class="block">Get a Last Will and Testament message's destination topic.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value. may be null.</dd>
-</dl>
-</li>
-</ul>
-<a name="getWillPayload--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getWillPayload</h4>
-<pre>public byte[] getWillPayload()</pre>
-<div class="block">Get a Last Will and Testament message's payload.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value. may be null.</dd>
-</dl>
-</li>
-</ul>
-<a name="getWillQOS--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getWillQOS</h4>
-<pre>public int getWillQOS()</pre>
-<div class="block">Get a Last Will and Testament message's QOS.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value.</dd>
-</dl>
-</li>
-</ul>
-<a name="getWillRetained--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getWillRetained</h4>
-<pre>public boolean getWillRetained()</pre>
-<div class="block">Get a Last Will and Testament message's "retained" setting.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value.</dd>
-</dl>
-</li>
-</ul>
-<a name="isCleanSession--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>isCleanSession</h4>
-<pre>public boolean isCleanSession()</pre>
-<div class="block">Get the clean session setting.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the value</dd>
-</dl>
-</li>
-</ul>
-<a name="getPassword--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getPassword</h4>
-<pre>public char[] getPassword()</pre>
-<div class="block">Get the the password to use for authentication with the server.</div>
-</li>
-</ul>
-<a name="getUserName--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getUserName</h4>
-<pre>public java.lang.String getUserName()</pre>
-<div class="block">Get the username to use for authentication with the server.</div>
-</li>
-</ul>
-<a name="setClientId-java.lang.String-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setClientId</h4>
-<pre>public void setClientId(java.lang.String clientId)</pre>
-<div class="block">Connection Client Id.
- <p>
- Optional. default null: a clientId is auto-generated.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>clientId</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setActionTimeToWaitMillis-long-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setActionTimeToWaitMillis</h4>
-<pre>public void setActionTimeToWaitMillis(long actionTimeToWaitMillis)</pre>
-<div class="block">Maximum time to wait for an action (e.g., publish message) to complete.
- <p>
- Optional. default: -1 no timeout. 0 also means no timeout.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>actionTimeToWaitMillis</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setPersistence-org.eclipse.paho.client.mqttv3.MqttClientPersistence-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setPersistence</h4>
-<pre>public void setPersistence(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)</pre>
-<div class="block">QoS 1 and 2 in-flight message persistence.
- <p>
- optional. default: use memory persistence.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>persistence</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setCleanSession-boolean-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setCleanSession</h4>
-<pre>public void setCleanSession(boolean cleanSession)</pre>
-<div class="block">Clean Session.
- <p>
- Qptional. default: true.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>cleanSession</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setConnectionTimeout-int-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setConnectionTimeout</h4>
-<pre>public void setConnectionTimeout(int connectionTimeoutSec)</pre>
-<div class="block">Connection timeout.
- Optional. 0 disables the timeout / blocks until connected. default: 30 seconds.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>connectionTimeoutSec</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setIdleTimeout-int-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setIdleTimeout</h4>
-<pre>public void setIdleTimeout(int idleTimeoutSec)</pre>
-<div class="block">Idle connection timeout.
- Optional. 0 disables idle connection disconnect. default: 0 seconds (disabled).
- <p>
- Following an idle disconnect, the connector will automatically
- reconnect when it receives a new tuple to publish.
- If the connector is subscribing to topics, it will also reconnect
- as per <a href="../../../quarks/connectors/mqtt/MqttConfig.html#setSubscriberIdleReconnectInterval-int-"><code>setSubscriberIdleReconnectInterval(int)</code></a>.
- <p></div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>idleTimeoutSec</code> - </dd>
-<dt><span class="seeLabel">See Also:</span></dt>
-<dd><a href="../../../quarks/connectors/mqtt/MqttConfig.html#setSubscriberIdleReconnectInterval-int-"><code>setSubscriberIdleReconnectInterval(int)</code></a></dd>
-</dl>
-</li>
-</ul>
-<a name="setSubscriberIdleReconnectInterval-int-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setSubscriberIdleReconnectInterval</h4>
-<pre>public void setSubscriberIdleReconnectInterval(int seconds)</pre>
-<div class="block">Subscriber idle reconnect interval.
- <p>
- Following an idle disconnect, if the connector is subscribing to topics,
- it will reconnect after the specified interval.
- Optional. default: 60 seconds.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>seconds</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setKeepAliveInterval-int-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setKeepAliveInterval</h4>
-<pre>public void setKeepAliveInterval(int keepAliveSec)
- throws java.lang.IllegalArgumentException</pre>
-<div class="block">Connection Keep alive.
- <p>
- Optional. 0 disables keepalive processing. default: 60 seconds.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>keepAliveSec</code> - </dd>
-<dt><span class="throwsLabel">Throws:</span></dt>
-<dd><code>java.lang.IllegalArgumentException</code></dd>
-</dl>
-</li>
-</ul>
-<a name="setServerURLs-java.lang.String:A-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setServerURLs</h4>
-<pre>public void setServerURLs(java.lang.String[] serverUrls)</pre>
-<div class="block">MQTT Server URLs
- <p>
- Required. Must be an array of one or more MQTT server URLs.
- When connecting, the first URL that successfully connects is used.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>serverUrls</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setWill-java.lang.String-byte:A-int-boolean-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setWill</h4>
-<pre>public void setWill(java.lang.String topic,
- byte[] payload,
- int qos,
- boolean retained)</pre>
-<div class="block">Last Will and Testament.
- <p>
- optional. default: no last-will-and-testament.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>topic</code> - topic to publish to</dd>
-<dd><code>payload</code> - the last-will-and-testament message value</dd>
-<dd><code>qos</code> - the quality of service to use to publish the message</dd>
-<dd><code>retained</code> - true to retain the message across connections</dd>
-</dl>
-</li>
-</ul>
-<a name="setPassword-char:A-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setPassword</h4>
-<pre>public void setPassword(char[] password)</pre>
-<div class="block">Set the password to use for authentication with the server.
- Optional. default: null.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>password</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setUserName-java.lang.String-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setUserName</h4>
-<pre>public void setUserName(java.lang.String userName)</pre>
-<div class="block">Set the username to use for authentication with the server.
- Optional. default: null.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>userName</code> - </dd>
-</dl>
-</li>
-</ul>
-<a name="setTrustStore-java.lang.String-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setTrustStore</h4>
-<pre>public void setTrustStore(java.lang.String path)</pre>
-<div class="block">Set the SSL trust store path.
- <p>
- Only used with "ssl:" serverURL.
- Path to trust store file in JKS format.
- If not set, the standard JRE and javax.net.ssl system properties
- control the SSL behavior.
- Generally not required if server has a CA-signed certificate.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>path</code> - the path. null to unset.</dd>
-</dl>
-</li>
-</ul>
-<a name="getTrustStore--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getTrustStore</h4>
-<pre>public java.lang.String getTrustStore()</pre>
-<div class="block">Get the SSL trust store path.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the path. null if not set.</dd>
-</dl>
-</li>
-</ul>
-<a name="setTrustStorePassword-char:A-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setTrustStorePassword</h4>
-<pre>public void setTrustStorePassword(char[] password)</pre>
-<div class="block">Set the SSL trust store password.
- <p>
- Required if the trust store path is set.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>password</code> - the password</dd>
-</dl>
-</li>
-</ul>
-<a name="getTrustStorePassword--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getTrustStorePassword</h4>
-<pre>public char[] getTrustStorePassword()</pre>
-<div class="block">Get the SSL trust store path password.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the password. null if not set.</dd>
-</dl>
-</li>
-</ul>
-<a name="setKeyStore-java.lang.String-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setKeyStore</h4>
-<pre>public void setKeyStore(java.lang.String path)</pre>
-<div class="block">Set the SSL key store path.
- <p>
- Only used with "ssl:" serverURL when the server is configured for
- client auth.
- Path to trust store file in JKS format.
- If not set, the standard JRE and javax.net.ssl system properties
- control the SSL behavior.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>path</code> - the path. null to unset.</dd>
-</dl>
-</li>
-</ul>
-<a name="getKeyStore--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getKeyStore</h4>
-<pre>public java.lang.String getKeyStore()</pre>
-<div class="block">Get the SSL trust store path.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the path. null if not set.</dd>
-</dl>
-</li>
-</ul>
-<a name="setKeyStorePassword-char:A-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>setKeyStorePassword</h4>
-<pre>public void setKeyStorePassword(char[] password)</pre>
-<div class="block">Set the SSL key store password.
- <p>
- Required if the key store path is set.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>password</code> - the password. null to unset.</dd>
-</dl>
-</li>
-</ul>
-<a name="getKeyStorePassword--">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>getKeyStorePassword</h4>
-<pre>public char[] getKeyStorePassword()</pre>
-<div class="block">Get the SSL key store path password.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>the password. null if not set.</dd>
-</dl>
-</li>
-</ul>
-<a name="options--">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>options</h4>
-<pre>public java.lang.Object options()</pre>
-<div class="block">INTERNAL USE ONLY.</div>
-<dl>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>object</dd>
-</dl>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="class-use/MqttConfig.html">Use</a></li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-<div class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li>Prev Class</li>
-<li><a href="../../../quarks/connectors/mqtt/MqttStreams.html" title="class in quarks.connectors.mqtt"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/mqtt/MqttConfig.html" target="_top">Frames</a></li>
-<li><a href="MqttConfig.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_bottom");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-<p class="legalCopy"><small>Copyright © 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
-</body>
-</html>
http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/05ad5e88/site/javadoc/lastest/quarks/connectors/mqtt/MqttStreams.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/mqtt/MqttStreams.html b/site/javadoc/lastest/quarks/connectors/mqtt/MqttStreams.html
deleted file mode 100644
index a3c1b99..0000000
--- a/site/javadoc/lastest/quarks/connectors/mqtt/MqttStreams.html
+++ /dev/null
@@ -1,510 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_71) on Tue May 17 00:28:45 UTC 2016 -->
-<title>MqttStreams (Quarks v0.4.0)</title>
-<meta name="date" content="2016-05-17">
-<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
- try {
- if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MqttStreams (Quarks v0.4.0)";
- }
- }
- catch(err) {
- }
-//-->
-var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="class-use/MqttStreams.html">Use</a></li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt"><span class="typeNameLink">Prev Class</span></a></li>
-<li>Next Class</li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/mqtt/MqttStreams.html" target="_top">Frames</a></li>
-<li><a href="MqttStreams.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_top");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!-- -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">quarks.connectors.mqtt</div>
-<h2 title="Class MqttStreams" class="title">Class MqttStreams</h2>
-</div>
-<div class="contentContainer">
-<ul class="inheritance">
-<li>java.lang.Object</li>
-<li>
-<ul class="inheritance">
-<li>quarks.connectors.mqtt.MqttStreams</li>
-</ul>
-</li>
-</ul>
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<hr>
-<br>
-<pre>public class <span class="typeNameLabel">MqttStreams</span>
-extends java.lang.Object</pre>
-<div class="block"><code>MqttStreams</code> is a connector to a MQTT messaging broker
- for publishing and subscribing to topics.
- <p>
- For more information about MQTT see <a href="http://mqtt.org">http://mqtt.org</a>
- <p>
- The connector exposes all MQTT capabilities:
- <ul>
- <li>multiple server URLs using tcp or ssl</li>
- <li>connection ClientId control</li>
- <li>connection username and password based authentication</li>
- <li>TODO SSL connection client authentication Q:expose just key/trust store path/pw or whole setSSLProperties capability? Related: expose setSocketFactory?</li>
- <li>connection clean session control</li>
- <li>connection keepalive control</li>
- <li>operation/action timeout control</li>
- <li>client last will and testament</li>
- <li>connection in-flight message persistence control</li>
- <li>per-published message control of topic, quality of service, payload and retain value</li>
- <li>subscription topicFilter and maximum quality of service control</li>
- <li>TODO multiple subscription topicFilters</li>
- <li>access to received message's topic and payload.
- Omitting until there's a clear demand for it: the received msg's isRetained, qos and isDuplicate values.
- <li>TODO dynamic server URLs control, operation timeout, keepalive control</li>
- <li>TODO dynamic subscription list control</li>
- <li>robust connection management / reconnected</li>
- <li>TODO fix: client's aren't gracefully disconnecting (their close() isn't getting called) issue#64</li>
- </ul>
- <p>
- Sample use:
- <pre><code>
- Topology t = ...;
- String url = "tcp://localhost:1883";
- MqttStreams mqtt = new MqttStreams(t, url);
- TStream<String> s = top.constants("one", "two", "three");
- mqtt.publish(s, "myTopic", 0);
- TStream<String> rcvd = mqtt.subscribe("someTopic", 0);
- rcvd.print();
- </code></pre>
- <P>
- <code>publish()</code> can be called zero or more times.
- <code>subscribe()</code> can be called at most once.
- <p>
- See <a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt"><code>MqttConfig</code></a> for all configuration items.
- <p>
- Messages are delivered with the specified Quality of Service.
- TODO adjust the QoS-1 and 2 descriptions based on the fact that we only
- supply a MemoryPersistence class under the covers.
- <ul>
- <li>Quality of Service 0 - a message should be delivered at most once
- (zero or one times) - "fire and forget".
- This is the fastest QoS but should only be used for messages which
- are not valuable.</li>
- <li>Quality of Service 1 - a message should be delivered at least once
- (zero or more times).
- The message will be acknowledged across the network.</li>
- <li>Quality of Service 2 = a message should be delivered once.
- Delivery is subject to two-phase acknowledgment across the network.</li>
- </ul>
- For <code>subscribe()</code>, the QoS is the maximum QoS used for a message.
- If a message was published with a QoS less then the subscribe's QoS,
- the message will be received with the published QoS,
- otherwise it will be received with the subscribe's QoS.</div>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ======== CONSTRUCTOR SUMMARY ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.summary">
-<!-- -->
-</a>
-<h3>Constructor Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
-<caption><span>Constructors</span><span class="tabEnd"> </span></caption>
-<tr>
-<th class="colOne" scope="col">Constructor and Description</th>
-</tr>
-<tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttStreams.html#MqttStreams-quarks.topology.Topology-java.lang.String-java.lang.String-">MqttStreams</a></span>(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a> topology,
- java.lang.String url,
- java.lang.String clientId)</code>
-<div class="block">Create a connector to the specified server.</div>
-</td>
-</tr>
-<tr class="rowColor">
-<td class="colOne"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttStreams.html#MqttStreams-quarks.topology.Topology-quarks.function.Supplier-">MqttStreams</a></span>(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a> topology,
- <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a><<a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt">MqttConfig</a>> config)</code>
-<div class="block">Create a connector with the specified configuration.</div>
-</td>
-</tr>
-</table>
-</li>
-</ul>
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!-- -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code><a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><java.lang.String></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttStreams.html#publish-quarks.topology.TStream-java.lang.String-int-boolean-">publish</a></span>(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><java.lang.String> stream,
- java.lang.String topic,
- int qos,
- boolean retain)</code>
-<div class="block">Publish a <code>TStream<String></code> stream's tuples as MQTT messages.</div>
-</td>
-</tr>
-<tr id="i1" class="rowColor">
-<td class="colFirst"><code><T> <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><T></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttStreams.html#publish-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-">publish</a></span>(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T> stream,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> topic,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,byte[]> payload,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Integer> qos,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Boolean> retain)</code>
-<div class="block">Publish a stream's tuples as MQTT messages.</div>
-</td>
-</tr>
-<tr id="i2" class="altColor">
-<td class="colFirst"><code><T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><java.lang.String></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttStreams.html#subscribe-java.lang.String-int-">subscribe</a></span>(java.lang.String topicFilter,
- int qos)</code>
-<div class="block">Subscribe to the MQTT topic(s) and create a <code>TStream<String></code>.</div>
-</td>
-</tr>
-<tr id="i3" class="rowColor">
-<td class="colFirst"><code><T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttStreams.html#subscribe-java.lang.String-int-quarks.function.BiFunction-">subscribe</a></span>(java.lang.String topicFilter,
- int qos,
- <a href="../../../quarks/function/BiFunction.html" title="interface in quarks.function">BiFunction</a><java.lang.String,byte[],T> message2Tuple)</code>
-<div class="block">Subscribe to the MQTT topic(s) and create a stream of tuples of type <code>T</code>.</div>
-</td>
-</tr>
-<tr id="i4" class="altColor">
-<td class="colFirst"><code><a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/mqtt/MqttStreams.html#topology--">topology</a></span>()</code>
-<div class="block">Get the <a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology"><code>Topology</code></a> the connector is associated with.</div>
-</td>
-</tr>
-</table>
-<ul class="blockList">
-<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
-<!-- -->
-</a>
-<h3>Methods inherited from class java.lang.Object</h3>
-<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========= CONSTRUCTOR DETAIL ======== -->
-<ul class="blockList">
-<li class="blockList"><a name="constructor.detail">
-<!-- -->
-</a>
-<h3>Constructor Detail</h3>
-<a name="MqttStreams-quarks.topology.Topology-java.lang.String-java.lang.String-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>MqttStreams</h4>
-<pre>public MqttStreams(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a> topology,
- java.lang.String url,
- java.lang.String clientId)</pre>
-<div class="block">Create a connector to the specified server.
- <p>
- A convenience function.
- Connecting to the server occurs after the
- topology is submitted for execution.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>topology</code> - the connector's associated <code>Topology</code>.</dd>
-<dd><code>url</code> - URL of MQTT server.</dd>
-<dd><code>clientId</code> - the connector's MQTT clientId. auto-generated if null.</dd>
-</dl>
-</li>
-</ul>
-<a name="MqttStreams-quarks.topology.Topology-quarks.function.Supplier-">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>MqttStreams</h4>
-<pre>public MqttStreams(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a> topology,
- <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a><<a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt">MqttConfig</a>> config)</pre>
-<div class="block">Create a connector with the specified configuration.
- <p>
- Connecting to the server occurs after the
- topology is submitted for execution.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>topology</code> - </dd>
-<dd><code>config</code> - <a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt"><code>MqttConfig</code></a> supplier.</dd>
-</dl>
-</li>
-</ul>
-</li>
-</ul>
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!-- -->
-</a>
-<h3>Method Detail</h3>
-<a name="publish-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>publish</h4>
-<pre>public <T> <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><T> publish(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T> stream,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> topic,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,byte[]> payload,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Integer> qos,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Boolean> retain)</pre>
-<div class="block">Publish a stream's tuples as MQTT messages.
- <p>Each tuple is published as an MQTT message with
- the supplied functions providing the message topic, payload
- and QoS. The topic and QoS can be generated based upon the tuple.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>stream</code> - Stream to be published.</dd>
-<dd><code>topic</code> - function to supply the message's topic.</dd>
-<dd><code>payload</code> - function to supply the message's payload.</dd>
-<dd><code>qos</code> - function to supply the message's delivery Quality of Service.</dd>
-<dd><code>retain</code> - function to supply the message's retain value</dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>TSink sink element representing termination of this stream.</dd>
-</dl>
-</li>
-</ul>
-<a name="publish-quarks.topology.TStream-java.lang.String-int-boolean-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>publish</h4>
-<pre>public <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><java.lang.String> publish(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><java.lang.String> stream,
- java.lang.String topic,
- int qos,
- boolean retain)</pre>
-<div class="block">Publish a <code>TStream<String></code> stream's tuples as MQTT messages.
- <p>
- A convenience function.
- The payload of each message is the String tuple's value serialized as UTF-8.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>stream</code> - Stream to be published.</dd>
-<dd><code>topic</code> - the fixed topic.</dd>
-<dd><code>qos</code> - the fixed delivery Quality of Service.</dd>
-<dd><code>retain</code> - the fixed retain value.</dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd>TSink sink element representing termination of this stream.</dd>
-</dl>
-</li>
-</ul>
-<a name="subscribe-java.lang.String-int-quarks.function.BiFunction-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>subscribe</h4>
-<pre>public <T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T> subscribe(java.lang.String topicFilter,
- int qos,
- <a href="../../../quarks/function/BiFunction.html" title="interface in quarks.function">BiFunction</a><java.lang.String,byte[],T> message2Tuple)</pre>
-<div class="block">Subscribe to the MQTT topic(s) and create a stream of tuples of type <code>T</code>.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>topicFilter</code> - the topic(s) to subscribe to.</dd>
-<dd><code>qos</code> - the maximum Quality of Service to use.</dd>
-<dd><code>message2Tuple</code> - function to convert <code>(topic, payload)</code> to
- a tuple of type <code>T</code></dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd><code>TStream<T></code></dd>
-</dl>
-</li>
-</ul>
-<a name="subscribe-java.lang.String-int-">
-<!-- -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>subscribe</h4>
-<pre>public <T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><java.lang.String> subscribe(java.lang.String topicFilter,
- int qos)</pre>
-<div class="block">Subscribe to the MQTT topic(s) and create a <code>TStream<String></code>.
- <p>
- A convenience function.
- Each message's payload is expected/required to be a UTF-8 encoded string.
- Only the converted payload is present the generated tuple.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>topicFilter</code> - the topic(s) to subscribe to.</dd>
-<dd><code>qos</code> - the maximum Quality of Service to use.</dd>
-<dt><span class="returnLabel">Returns:</span></dt>
-<dd><code>TStream<String></code></dd>
-<dt><span class="seeLabel">See Also:</span></dt>
-<dd><a href="../../../quarks/connectors/mqtt/MqttStreams.html#publish-quarks.topology.TStream-java.lang.String-int-boolean-"><code>publish(TStream, String, int, boolean)</code></a></dd>
-</dl>
-</li>
-</ul>
-<a name="topology--">
-<!-- -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>topology</h4>
-<pre>public <a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a> topology()</pre>
-<div class="block">Get the <a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology"><code>Topology</code></a> the connector is associated with.</div>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!-- -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!-- -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="class-use/MqttStreams.html">Use</a></li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../index-all.html">Index</a></li>
-<li><a href="../../../help-doc.html">Help</a></li>
-</ul>
-<div class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a href="../../../quarks/connectors/mqtt/MqttConfig.html" title="class in quarks.connectors.mqtt"><span class="typeNameLink">Prev Class</span></a></li>
-<li>Next Class</li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/mqtt/MqttStreams.html" target="_top">Frames</a></li>
-<li><a href="MqttStreams.html" target="_top">No Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a href="../../../allclasses-noframe.html">All Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
- allClassesLink = document.getElementById("allclasses_navbar_bottom");
- if(window==top) {
- allClassesLink.style.display = "block";
- }
- else {
- allClassesLink.style.display = "none";
- }
- //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary: </li>
-<li>Nested | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-<p class="legalCopy"><small>Copyright © 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
-</body>
-</html>