From 91165ef3f969a311d4625bb3ed521a0ab094f87a Mon Sep 17 00:00:00 2001
From: Riccardo Presotto <riccardo.presotto@studenti.unimi.it>
Date: Thu, 29 Apr 2021 09:44:55 +0200
Subject: [PATCH] update MQTT exercises

---
 .../6.7/executionHistory/executionHistory.bin | Bin 117584 -> 117584 bytes
 .../executionHistory/executionHistory.lock    | Bin 17 -> 17 bytes
 .gradle/6.7/fileHashes/fileHashes.bin         | Bin 23047 -> 23397 bytes
 .gradle/6.7/fileHashes/fileHashes.lock        | Bin 17 -> 17 bytes
 .gradle/6.7/javaCompile/classAnalysis.bin     | Bin 21512 -> 29778 bytes
 .gradle/6.7/javaCompile/javaCompile.lock      | Bin 17 -> 17 bytes
 .../buildOutputCleanup.lock                   | Bin 17 -> 17 bytes
 .idea/uiDesigner.xml                          | 124 ++++++++++++++++++
 build/classes/java/main/MQTT/PubExample.class | Bin 2832 -> 2897 bytes
 .../java/main/MQTT/PubExampleCallback$1.class | Bin 0 -> 1833 bytes
 .../java/main/MQTT/PubExampleCallback.class   | Bin 0 -> 3291 bytes
 .../java/main/MQTT/PubSubExample$1.class      | Bin 0 -> 2409 bytes
 .../java/main/MQTT/PubSubExample.class        | Bin 0 -> 3789 bytes
 .../classes/java/main/MQTT/SubExample$1.class | Bin 2029 -> 2252 bytes
 build/classes/java/main/MQTT/SubExample.class | Bin 2832 -> 2916 bytes
 .../java/main/REST/services/HelloWorld.class  | Bin 1286 -> 1286 bytes
 .../main/REST/services/UsersService.class     | Bin 1888 -> 1888 bytes
 .../compileJava/source-classes-mapping.txt    |  14 +-
 src/main/java/MQTT/PubExample.java            |  51 +++++++
 src/main/java/MQTT/PubExampleCallback.java    |  68 ++++++++++
 src/main/java/MQTT/PubSubExample.java         |  91 +++++++++++++
 src/main/java/MQTT/SubExample.java            |  75 +++++++++++
 src/main/java/REST/services/HelloWorld.java   |   5 +-
 src/main/java/REST/services/UsersService.java |   3 +-
 24 files changed, 421 insertions(+), 10 deletions(-)
 create mode 100644 .idea/uiDesigner.xml
 create mode 100644 build/classes/java/main/MQTT/PubExampleCallback$1.class
 create mode 100644 build/classes/java/main/MQTT/PubExampleCallback.class
 create mode 100644 build/classes/java/main/MQTT/PubSubExample$1.class
 create mode 100644 build/classes/java/main/MQTT/PubSubExample.class
 create mode 100644 src/main/java/MQTT/PubExample.java
 create mode 100644 src/main/java/MQTT/PubExampleCallback.java
 create mode 100644 src/main/java/MQTT/PubSubExample.java
 create mode 100644 src/main/java/MQTT/SubExample.java

diff --git a/.gradle/6.7/executionHistory/executionHistory.bin b/.gradle/6.7/executionHistory/executionHistory.bin
index 08f5652dab4ac9d2fd8aaee03be0066740e0c11e..cf68230edc9d9ba5be3c1c19c012d35607759a02 100644
GIT binary patch
delta 869
zcmcaGjs3zj_J%EtzNzXa$+OMMP09-^a?Q%iGR!NIO_GevvyJl73bV};8Nh(mm0|Pb
zKrhkh6Veztre9BGRNKBimGPN06W`(Kj2(<-)9YIqd8a>WWLzsyQ86`zqmfzQgb35Y
z8S5Anrq6F;6k~h<SH?HJvWb!3);TdJCn+&GTQ4iIERk6te%keI>$rBWO<&gCX{yYr
z$~f0IFeF4jpft&~A~ClhCly8g^uRtwbC8{UCNO2eaFtLK1HL>J-q&5T_Np0|=<$!M
zBpGMGl}=yY#F#1Is#La0cyFQVpIy$y|J8Qf-LBBg*ux~?RQ@$PwnVd5EYRT174N^X
z)93GIl%IaPl`&1g_GFl1<cbUSu^}AaCZ4y@ogUc6_)5dpQ#L+w?-`N1X@Or}TcxdF
zo|=+cT#}iWSdy8a=aN~Jnp~1!R4I5C6av26H?%XxF$&o~+^w&($5*5>`~1ZpzIXc>
zAA@9rrvL6>6l8o0XLGB-yscuWmz<MWT+A$B>yxs))AH=4ZRe-`<-gq6kE~n}UHNN-
zQA#j5m_gf~e2ZFIpEqwd_nMqX+5&4CkreZzDt-Yrh6NNI(*=(+iU`d<_TtB-eu-P<
zVuw89lUb7)Au7Z{DiARNbM!N?b`4ZXm^1uikAM5(b<Tvtq&9Er2kA465Y?<;)zeEl
z8Ow#3jLef3u-B)EaEBbvIy!wT<5P&Y{JR({g`R|On%m|gb0Vg3(S~-f8<$~036$iX
zexQqyZM$tZqb-Y&c}J+$k5>1cbHeUEsXZuL$@pfvV-I8S^!xpcT|$Xsn>Wo}q*m6y
z?EcZ$54;yJzJo}{_cL-%*K1?s-Tq_(qY<M(&tjjC`H8bvv7auy#c6R}Yx;^4j2heh
dCNZvKVlpY%{NUyu+39wTjPctqZfC3)1^`D|SKt5u

delta 379
zcmV->0fhe0mIu(52Y|EzO=Tx9tD81;YjZSYWO{jGWHxYPWMp}3Y;$BaVrVyI00000
z000BB0JD=(N)?xoW&sG7*JS}Fx3^^h<{JVG!<S)(0YjJKfdQ=$#zcZv!c1O&k6ULF
z1;b^Dm!E<G7MIO~0b3AkH4XSA<=ZI6Z<oE}cURB1ID`R=0+)}w0WX*Hh5=@m9J~QB
zmx_l0$tbUmu5Bw`o0S}V`J~pG4!#4GWMy-7X>MV3X>V>sX>w&_bZ>Hb4b7Lqi2+Tw
z$cO=60T7-v2qI=GO&(2^sI{u}bC;Kpj{#MeaEk#7mmZ1%2A4aI0ca8~XE{}D=?3*&
zhr?EvN{o2{<(I*U0aKTcjsX&v8jk^H5FM@KnC_~)_&-clyiJqPLbs5Q0ipz#ro;ge
z0qmEtlmT3qpp*fDmxaXv5w|jx0h|F4fD9}u)vn7L-J}2-ug7jNx89Zk)&c@AxRZ;h
ZK$kms0THu#)gvO8K7j#Xx6-!(eiLdwoALkv

diff --git a/.gradle/6.7/executionHistory/executionHistory.lock b/.gradle/6.7/executionHistory/executionHistory.lock
index f5d327842988626ef4b0ffb4ea5e166f45cd1f29..764860d31f678bd696584538cc55e5d9d0cc14bd 100644
GIT binary patch
literal 17
UcmZSHUU)b*s&hv)0|Xof05<mp1poj5

literal 17
UcmZSHUU)b*s&hv)0|ZzA05)s{dH?_b

diff --git a/.gradle/6.7/fileHashes/fileHashes.bin b/.gradle/6.7/fileHashes/fileHashes.bin
index 7b5bfb4988a7b0e43abc483baac5d9eb672035ef..59d8ae85875a05cff86a7f1941d9eb44d3201092 100644
GIT binary patch
delta 1018
zcmZqQ!uWI>;|3E6#-z=r5*&;IvoCl~P0YN#m;nr;EH|4<zF-u%82V+K;nT+5P|>-Y
zMWqdx1b#o;(x2O?;06_CpKL4Jpuwj$-%&L)K?W+A{T~YWQxCC9R8G-^h(|MS-YN?;
z*e9T<L{9AaKd7kj<f-yA1oHdDds1T_9fKNiezK~<A|_79jfy|SHyYgF+wAD^j4#kt
zsce<--a^$syPS*vtL?bUz`$53)2qh;(ZpR0r1gw}1js@~5EiJYn3}@T$SiO|gz4an
zbqoq%9X)#v040HdeR4&(IuBp<jRjyX1GCQLiNUI@l^~JHyMuLED}{^?C`^7EELCrN
zGE6aY#RdD=5RPvX&s*q%43ao0*a6YVvKmOES?yH*H9NLMvsNt7;LR29zp)@4LYm7A
zAUc@NVd}7dxLaRmkFQ8&_W6rHeDC%{yvOzfsInf2xdSn^JPF@4x6MW7L`>tN4eeex
zE<?0<CID3e0e1?JKywz8k$KVr_WBeN?vUeIN2hN^)xmKFQ-{|YFN?|Ykpe7yHFgG*
z*M~|?jt>(C1<mb>$*GZgW*}jZZ43;|i+}{0edZmZT0dIdcg_jB`=s`uY$Z4tj7lUX
zdxuI%B#Ld`G<T6&S^u*8M_)hiUI6p)<l0cF`adhU&G&40UH9GafT~&5-4`H9z6l4Q
zcCm9}+7&<T`nGjkyVs^K>+UpF=2Qjg5HXfY0ICE6Y@reG<*D$#?wYk%&A3F5e_SOA
z(jor;;R2v?P>}PB0SPn@`Ntmr_QmU*35Q8--qa7$zyJfLgcW`lfGUB2?<|l&(_!nA
zvb@vs?4@nzr~T!>+z5_WgbsF4YDLpA``C*gL6`a^Zk3B2@`z7nO-8kZGZRzGwkO}B
Xme%LZo6Wr@=aII+T2vi8w?R4pNq!ES

delta 420
zcmaF5jj??T;|3E6#^}wa5*&=1LnR+DZuXVdV4B=3Td~<x?g8UuU4;pguPV%9;+VNn
z@rU?Eg9iT1jvmkW0&`4xf2cgYt#K@W`rgOo;pZ6`7%O>x?)bp~2HfdDO3xTbXacb!
z2n!r@X$m{!6Ib6Koi4<BIJFb3<I8yspd=7*POb=7=i!0#nRO;l3|3{W1c^-E9jpsw
zy$zO{Y#Aa9<pqXFO=gGl<U^$D=b3OQrD^%f`A%K2b=8;R>0nE~t=<8#gj)beqd7}<
z?c*8mR_*y=?-RPmck%@%h(`{bz^y|s-7+-iCEM4S_QPS*y?QE<bg%+-vA><n8L7s?
z1GIJW`cSFK@nIn6f_SNsdORQo#AxP4lk3AkJ_Jd50~H<)6BY#XAoA=9Kw1v~URZ$j

diff --git a/.gradle/6.7/fileHashes/fileHashes.lock b/.gradle/6.7/fileHashes/fileHashes.lock
index f235325ad01d016949d55ffe4167f0dab0f64a7f..5364a2b05eb42472f8ccd1c502f208f85ef02f15 100644
GIT binary patch
literal 17
VcmZRMJbXs##J>3^3}C=$3II2T1eE{)

literal 17
UcmZRMJbXs##J>3^3=q%&05{JB-v9sr

diff --git a/.gradle/6.7/javaCompile/classAnalysis.bin b/.gradle/6.7/javaCompile/classAnalysis.bin
index 95cfbd7d9e6754d8632eba78d9c6e6b63b8fb010..171f0c01e68dccad4143e6a46836bd4862ac1fb1 100644
GIT binary patch
literal 29778
zcmeI42}~4M7{_N7thHFJ)dp>~YN;_5M~#Mvp*4soH^{EHsKf3Q7ItTro#j{?qqZhq
zMWKpCTD4LyR5V3xdMdHiV!YehDntvl9%wxpwMs?pd;8|ivdgNVS%meQ<jW4fdGqG`
z{@<H#-puSWl3{#1-j^4~zI3s#!Wt+53V;Hj04M+ofC8WZC;$q80-yjW01AKtpa3WU
z3V;Hj04M+oc!~mJQ6TL|Fuwk+@JfeFh8gICRs!Z^2E@JQ+rvyY8@AB*2XiNmNVt$!
ze3<ZeM^HXrs#&he9JY|~7+=b>ODo202&$Y)cwD){f0||fb9HqU;jw)vUtHDw^LD@Z
zj37L`2j#h|{~BC!uy6q3`Z1I*>vT2m@ai_jglpPTp8v)Ez=hoK0=fSp%2!?si@X>;
z`*p&_fs}8!-ot-~b?JYE$B2|~tn7C)dxvQX;gOY;|2XaIA1(#QcOZQ1Udj)rY;84f
zOLZaP6M9m9bm)yPy4F80Av`6L@?%5iuAh2(PbA@~ofUq(&G)6=KHUi)Kc4dP&q_Xg
zvu~*E|KtS9tAe^F*P7b~k@i!|C_lgBR&M2*(5r-x;VHk+vuxi9s~ARj+AW3886XDf
zUy}Qoo=5qm5B3a*(|X+_?KQQOUp{ee{>2HK+Y>%5m+~v?qgL$f>=RCS{AkK=Z1jKo
zTye*{geNYg{B~^jeP>7SiXnW85^t-j*m$mNcyGd!7Sr}#J!dY+udTg8_=IZ8eRsF7
zS+!)~al*}|l)t)t&9bgR*+&RZsG+<!%a;#Ww%dzvA&K&S{kzVcSh9aJ;n8nVKIG2L
zTfNh6r_22)`3(@#UL3YF|2M*;Qfd2<mb*ua_pj3tt{$%N^5}xVip-6KYd@wuBJ}mO
zQ`D>O6RxvT9(i}RE^pc_S!dG_%A@*}2ZdC1lgDRxI_1%qZ-);%Rep^0GqHs7n63QI
zzr7>w5T3?TJ|=eN?`uzd8bG+Tfb#f=l0e<ngqI1A@K^ZCPH#N#)9obTNiR@7$&cMH
z<SeWq+^FPha!!TT&@M{$C-n?%KRxEa<eG%#H%WVLiNX(69l8@;Mlh4C=&XCCV*3`6
zSxGkV5^bNN&-hLk;y;n_amsOp!soJ&R=y+mGwD6r-de#X1Qz|FCL1EQQ9fhbtiXG{
zied>53#OcYGK_aGxik0x1wa8%02BZPKmkwy6aWQ40Z;%G00lq+PyiGF1wa8%02BZP
zKmkwy6aWQ40Z;%G00lq+PyiGF1wa8%02BZPKmkwy6aWR9r2>PISHB`Vh;30^dSYl6
zXEYgj?5x*j(VWEcT7%vs@vMnU7Fo2;3l`RxX0c=pW~0$ZG%rb95?|7QrXivr@LEf(
z$)Xnpski}qgl1`ZTkA~?XdGhm4LdF`CvkB2Tj!&&<(PTN!Y1;ZAhBa5UjFq1!>Ec<
zxC}0f%`zI;M7^M6IYAID9QKi&U^K*wq9xS88&TMDw`$z&R%Gk3<vMjM;Z~}35AD<5
zU+YZ|Z5XW8B6&r##%ki7{co(>+p*g-km1P9D{O8f88Y<f5NsH4Fo@$tvqAncJ4*g?
z;#sD|nk6=lvn0oHX3m)BK+U2q9qpb|7mg0q<ktNg?~0Cyms!XKRbOO1v3=s`0?vt~
zCJr%ZX<biQSu5g^Ry6Z$JTIBhP~!dQ%7}EmLC2fd)OEnIr5dF+9Ve-+>j0f)c8n!f
zttoh5-!8Rrfana6(v1xkOw}Lf?0sZ7Z!?G>C;+ns>qLfdt3s`4WTkY06?hAqY_Xto
z6>nq1&?;&64Q-Kv6y~igXVSA;QLu1&0kw0v%P3B35zSU~RJzQ=u6&6MkNmCKYNb;6
z4Z=-Si|hpb*}4&>V@pHMZO&jw<g}@eDl_4@B#q<^dZd6=Bc}2Kb`CAyV)xG?JB7{B
zS;pHToJSo4AHt2L%oc*p^=%ChCRnlx+Ip4mB97Kx`Qk&>8aGrvr*0*5O!rhirvp7<
z<+JsMPm-rs`5axSU-_H@mYSsUHA$t*aSF}xpvtAfx$@cedYY9F{}>AY!0A{{^canX
z^{k1~X<RPw&j`<BBM~~3bH@84TiAB!H^>9Z<P98mDYCDy)ejL-M&&||W_NYlivziY
z><l(nL)5zw7i2eQmgsChgZu_P*6jY8i{#bq6e&TIXUB*&&*YUN&upX6#c*T1>JLpf
z=jgFAVjG1@AoYDlA<~T43khP7kq6&iKiM5HWaLqgFWfkhx7{Z=Ka+5k5qo)(@1<N6
z@aB1rc>b*DA5@>Ju`Q+ZK8Mo9xc9o6SO1`XgWUh%>|cjVYfHZ(9YyKG|7@VFfT}4!
z;|!4>D#&MD{sT6nU7Ow6cN}MEAF^H8Tn-bofl;|0waqS^0}cbOrOzDjKj65I?I9z|
z&4r^;HR8eN#p6r^RSZt%vs*VI`wRmbFbvF%Ja=y7saM{XKGn0o-gJDz-gK`wnFZ+L
zHwRm;)01uqLEF-pcfL-2H1^HMVst64^TO3p6nO2x+Fx#y)R5N>&+go%6v^NbPa!?E
zK)3W;BhQ}{dF;~$r8czmF$gy&&+_fLGK^dLTvrLCrJs*VAdr!Ve#N#)z9+Z$e*tX-
A0ssI2

delta 67
zcmccgg0W)-;|3E6MuEwx5($&PN=Qsrl{A?AS5jhfsg%TIQ)!9GsnQ0M?*eIC8HvfF
XvQ|ut6E`aU5Z`FfA-37k<2W|}B2X6u

diff --git a/.gradle/6.7/javaCompile/javaCompile.lock b/.gradle/6.7/javaCompile/javaCompile.lock
index 8c2e48cd28ad20826164cfc5876c303305e6df6a..0042925bd1410ce2bde3e31d8f2ae0a941cbd577 100644
GIT binary patch
literal 17
UcmZRssg;yV;(Icm0RmP704A3M(f|Me

literal 17
TcmZRssg;yV;(Icm0RmJ3CJ_Tn

diff --git a/.gradle/buildOutputCleanup/buildOutputCleanup.lock b/.gradle/buildOutputCleanup/buildOutputCleanup.lock
index e395a6aeb70677c15535d679bcaf6c63d9cc6321..5bed8506330eb7a9ea3cd5707c9ce1e82bf489e5 100644
GIT binary patch
literal 17
UcmZS92~Bz((7uR^0Rj#K04hiX7ytkO

literal 17
TcmZS92~Bz((7uR^0RjR6Db@p~

diff --git a/.idea/uiDesigner.xml b/.idea/uiDesigner.xml
new file mode 100644
index 0000000..e96534f
--- /dev/null
+++ b/.idea/uiDesigner.xml
@@ -0,0 +1,124 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Palette2">
+    <group name="Swing">
+      <item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
+      </item>
+      <item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
+      </item>
+      <item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.png" removable="false" auto-create-binding="false" can-attach-label="true">
+        <default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
+        <initial-values>
+          <property name="text" value="Button" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="RadioButton" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="CheckBox" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="Label" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
+          <preferred-size width="200" height="200" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
+          <preferred-size width="200" height="200" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.png" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
+      </item>
+      <item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
+          <preferred-size width="-1" height="20" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.png" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
+      </item>
+      <item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.png" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
+      </item>
+    </group>
+  </component>
+</project>
\ No newline at end of file
diff --git a/build/classes/java/main/MQTT/PubExample.class b/build/classes/java/main/MQTT/PubExample.class
index cbf5848d90467622e2c80eb309dccc545bf411a2..096af4d968d638287e8d55194f6dea477fa9c366 100644
GIT binary patch
delta 1519
zcmZvc+jCP@6vlr$m$OfjL#g3XB2`i-P}-8v77&9d1wqjkst8iNhV+mY(xfB-0hIs>
zf<*;`3f}K{cdBE`&>3Hy;l;rjeDt4i#$m=8aqYI$4&#|*uiLlQ`qn=C?9(%^%q(60
z=hDx>Qoaw;!WNsYLHs;wvrW@&)a{zbf@rpw<?#Sd@TBIcAR*%k@w83S$Q?ma^q2(K
zW@nHzz1He_sVq;BK6Yt#8<`1GL%&(FHaU9>114vWP2R|YS&BA$ZT4xNvDqJF9tTW=
zgEr3^<2jq>jXY#iGV-tq9<e!Uj2AR7YL1=x{a|@ewcC0ic_5QZ_LQ%xu8@_=^tsuh
zqN$^N+BdIy?Wnm@;pul3G2?75Z}V)eUN4htj?3J_Sy+^R^3*MDrA;xtm>NjL<C$D4
znd!|HiiwsLE7}}h;)EjHo9lPu1vgvB<qPplU%IzguJgvMR!%BfOvmzws;YK)nL*7d
zhgW!2QB%(8noft;IIWl#U7O2h-BhtJn~tu@=XSgKsKXgfXkK?HbJpPv-c$r{;M^X~
zTMp+qFMJ)|<{d@jXscRZpzB@Ub7<v#hY$ErF(cZwcSokL&}*vqyM;nB?IxlMUo;kr
zIef&&GDNg<ED#+S!@4~VpYW-}XS9_EeB0VT=YnDTh2-@Y(n9Y`GrUi>MD(wWZl#iY
z3$9pS^NoRiD=v3`${i5bcTy$bPc&4g-K?8W7TvLzu%Soxwqa4nuH?RCJd@0(<C}|l
zp}Df$?!WY7*jlE-p}xZS=C}g(HZ0m+UZ;O8Es;ZO9uG=JZIgAWSaFd`q`z?(H8dJt
zCaX2(WVz_hxPAvK#0qdH3Gqm>=NG{RK%EMEIxphg81^N6{^kA={N2rqhp{?F(A~q>
z2`gfid=&ye5F8;SE@yFtDd8$vn&n?%YK7{ih*ja1n;_wdaMeYoO=tS<)J0|{^awTG
z5nW-{Fp-2Ev1j-z+<H^)Y{@m4DdE}*rHL-Sh+W~fo3OV}^l7Rv=R8_O^gm3vPU54S
z=S~1Ga4um@g49dIj4;2#g0YDv1s9gaqYV@JlcI~pgN^?e6ego}Wv7IJ*{MmHvGL$|
z#Pp93$?K`&PyUk6+>3dgd1^}{Y%v3JH<^1NB#<g*F_k*1Stz&6y<$B;L@uY<?4gzt
zb2v^^j%^)7%;hrmTwy*}Ss=w*q<kaSXi_t1R;?^nn~13ladn&}YEX`tIXgS0R~^5x
zlG0srSoUy~RopEUN))+=)k0|&f6&ev;e1U#+_gf(GDnJatd{~_b&~re!-H1GxL-6c
zA$5ceqWP#&hlKKjauaq4b`{?1!Y-ic)NIsj8v7|tm!?Uqhv2#lWC=hh+z2CphyUiR
LFxV_rJUsF*sw6Vr

delta 1344
zcmZXUTXR!Y6vux%O>$07PYa}JF<eTZf|NqjLb({!QmUd*DhdkqLQT^{TF8x@6cKA{
zQRJd1cvSF)ctyu2WF}=`#t-1=IL!FqSMbRh$0wap*AAt2@JzDzUTgi=f33CG-up(w
znTGN2|GxGe(81RhtJ!I?%j9vBCk%F51lVKHXJN2Y4^M`8il+^pv8dLXYWAA+>-kxW
zBm>$ZWilAtv|1?TvvAlK+%)@^lxE0a*don-izo*yc1OvWWKD9~Id4+X^FfoMiEB_Y
z8L_yNLpsQFCWp1~yvY$gzhE+|=NGkc%w${(FBwc296kH<k)V}5SSodUzpAxfuj&e!
z#bj=9my<1c=hP0b(Rb3=V(_xW@FsnWd)LsRh?G)=L_D6!r;?eWyjx1NZ`iO#QC)Jf
z{jQU9``g+Tv7vm{iEA-mbmIfgU@@Q1#syMvipkPQ(NQ#e6aJ>!?#!^0E7`2!6-B#N
zd1I=!#^xBW8XUJd!AWndYQff1yru}py7Rf5lPV48(y`6O`~jzE^E#&u-mrO-Gd5>=
zOJUuDIfDkC&D*>qRoJ}CImL=fkWRyxWpkeQbm;eOKHx*I(Z6`%M_kZhwmYtyOgpi{
z$UtV;9dZV3KBmJ<`uB8Q<P)1ye5&wg-E_?6GfvA|_Cwa6>vb@d9C00yzTis@y(B8<
zaLOr&>MLRS)1UD62CmjemN)n8PaaCfGs#>!zOz)6sy1GU1lKFC-}tevUCx^Rd??AW
zL&mjUr`fP|o#=uhfysIq?aDg92JRLqM1qYPD~=Zg7Xo!6?CS|vZ4di<{p<YK3G}tB
zoFteCco)s+_{uUh;aVA5<X>i1nc2}mG+1WNw^-My?wiD}V8YY(2z6JfkI--+b(K33
z#&x27QKQVfN#-Zas9EnXv*0%Gh2pI-HQ~l-o@iiIblfbn=r(L@2BOU3|E%F9VyPt4
zG!41L`9xp_WT{x9fila=+;y{@8OG&P#^z~v?^>ujv|>u#;$03!Dm$VXR+VY}A47Z!
zI%Uzgw#%~LHox(^+^s5fe{#&Pbf$_L=|Qb@VU{53m`j8h^(>Q{-OW6<3NA$>E{m98
ziJbN(#=jAoD=g&)mUDw<Azm%iE&RbsHHTHIl~%QlxEi8O9i?3zmuBmOuutBSx%|RC
z+$--xjGwrVP6_Wa$|kzxahj0CHcMbrxIFIX0l~@f;6b*Cf0a7MLv-~>H9;YMSX_LB
t)VO5XC3V?qlx_6jXS;wG;QL3i3K;YnJaY4=PzF2xlKZB3R4_gs`xjX+5QYE%

diff --git a/build/classes/java/main/MQTT/PubExampleCallback$1.class b/build/classes/java/main/MQTT/PubExampleCallback$1.class
new file mode 100644
index 0000000000000000000000000000000000000000..cfcb1d13d55f5e5aa95a55b4f44039e74273c701
GIT binary patch
literal 1833
zcmbVM>vj`W7~LmHJLxc#P-p>*kZRDhp&e=wwMDR`MN<=KO{{X!wI-9Z(t*iLoS9U4
z6dyyE1}|&*06vt<eUeF&5?QD}=9_c-_TJy+oIn5i?GFIg@%0okxTfPYR;Ta|)-+t#
zk;1An@1}7>$9s5RO+L`Ej*Szzi4W7brQ<d}Qf5=_-O*6gu%%&Jz&Nzrob5W&i%JcF
zner3s&@x@iYns(4aJ=S*z~oKGbD~=Uv-$Du#eIQP(QinBQ)S1K_d2b*3~E;0<;qOi
zw=H+y3LG_$7gN!J6Oy^)c`_)vRv1c7=gXD7TFu<;)VII0T5VSrE!VAE_S4)dB}}(u
z7+Oua83fLuq|nWOkW%)8rYRXrJCtVII`GYYU}o!^C^}p-EBsaZI2%g#MC7*}TR@A!
z1+M-V2&%Gu#$ZQ|@0I;95;#Aqs&)|g->SI#WVY1_nUdL&6b?@aWE#?CXu-3hucD85
z^hW+wa!M+st=O^VKb77fFb)OQ{)fN7$!f&3SFCniFTLt_0$bj7R7KB?7idMb46DEG
z*{&b5Whyc{@EaQL8u%EW7&wEo24+#xuw&p;l!@|Um)+?&ZbJqJD!9k(Z1E_ugp3xl
zz2vQHxNl$=dj>wko`$M{8s;>7ZeSl@2rOjd>Sp6y%0_lM%Op#yk=-qAt!FiSY2X1K
z8hC`qitH<a3oq?E7G<dOe*Fn6El~IuO*Uv<M)DGH-kFx=utanDM<WdpUpdvB$-J^7
z0;<o#NVd4)cPJxnBgZ#)c}pWYN~@*rs?}~wj~8Tlv=s-qV^ne8>3C)s>QP$?=uJ7e
zG6HAwi(>%vOh<kne*kh^6z^ACNpu<Q>MN2r-p`cagu^SrtUNrHm40>Ew00*5_=pYW
z$F=rXsda+!sCSMyI|3K;JL3@zQi5xIYEOfY7(^zcnwT$eir*~exO%Sl9w(6CUtcQx
z46*bai61yi;5_Xl&w!%~v_@~N<2795OyG4~iV<#eo>XfuI?neTv;EE3QMq2G3<WHZ
z#R91W-oTr*O3q`RR&sJbBKbQ~51wOU=_iOTCTBF7LKkWNx|r%hAM)uvpG!o!+~b_<
zV;phjki!)+2)u>2W2T6SP)ugwSDX;|9{F)fgIvGhWEaz2oEnlQd)b-p1$G5f1YJRX
ngxEYHHo3k?!X*+VAy#M#942rT%lxP4Xkwltorf~~1L?m3mO#bj

literal 0
HcmV?d00001

diff --git a/build/classes/java/main/MQTT/PubExampleCallback.class b/build/classes/java/main/MQTT/PubExampleCallback.class
new file mode 100644
index 0000000000000000000000000000000000000000..385d647c7844796fa376ef87273f57ca0d02a62b
GIT binary patch
literal 3291
zcma)8`*##q9sk^9cW1I05*iX99I#78*#OCsrlq(63JFw$36CbCf%=&2UN!@}Gt10u
z3iYjReYDk9=u2&V)>dt`P~F5v@$C=(CI03)`jf|Vte@}hq#@a~XY-hQ@Av(__wWCE
z^Cp11@Yf{n!2>2fo<tm<F!4zPpOUR@U?vFz56CCihCH-^^GUP|q#Xqlv$8r#T);(P
zD4HlG;lh(oS#XyO_(^O;Am}iO3g!}rcTg*Tl6Vl84P24+p(M89)AIR@iO-t&oX~&X
z#1~}!qI|w&;>#u;Ht>jvN0aEoS493-O?*ubUpMiXtdE;`Le_5x@|z}}l*3a7zGdL5
zf;Hy4+8-_2L7)SL!~w^3!b1wJ>Ao`xu~9Ft6*|WqSD&bqX0$(L&lCyi8uxN`@r>;|
za*lwpaMq!W-tmdkQ&X8!m6>Cg?NYg@N9|&9#?D<FrofWzxC$H7=f*GCb9Sa^yM@eT
z=sRv<SQMH$&vj3hLy8$1_xwUe=Za1_(3!G5>t(ptZkQ=u3d6af%mkNFlIvVZ4##r?
zDlp3Sm7-_o#l!{;M3;0B*adp9ry21Rb!y5@)O9QDZia8PW+>TON>nw_49l_0IbHKY
zqGbC8MqtAlL82uyzIRdk604e)G5Q)0y|R;I)-HMEQ)3G2CPPMi!Y<cxV_<>>Y~UKp
zm*vHZQAkdD6+fr%b0nXe8nZPZ;j{1oWEHx@TsfP`6ea1iUJzyn_wOIF@HC!LxNX)e
z=}e&A!1IGls7qyqzGhNavtATDt1#FM!-`y6cn;4S__l@b;Jb8Sb+Sh)PBE{23oqbB
zhB6gZ3JWbYQVU?p!uRluf$v-R0e)!VNBA*ocZp8tQ~jx_Szp`v)Tyzf*_45oEc^s7
zTX+RO6{$ZX^*a>$jzMvYGJlR&4ZLRI7x*QEZ{c-ZSJ>5ruTkMyxPdoB)~_u58dZg!
z6cbf+f?4q+s^x5o6_Xkm7_cyp1%>UYh&xrT(>C~G;Wv2G!lI-$841)r#cWOGoj_WU
zJ=MU)o@v7Jx9gbA#^?o}%Rv7Yzmt&NlmQSF2>88JPK@=${U2nX$k~-Z^YlmjNl5=p
zkd~Gp=r3aDrgw<7!usXZpPacs%U6Kv!-b%N=Ag4fUGGiln(lPpS~Fs2x)It4k!jT#
z=y0^CZFiD$f&+*yrOyiD7Lz8g1ndd6rdOe1J#|5jmpR3m7t%Owmt?%y<+65ZQ~w&u
z8?B6rn~Y}YEqS=17KfFhWgv>8B5mtgOEir&qJ%5#OE)vAR?Xa1{?>bj11MMVeNOA8
z^U7e?p|n3<(4pjl_swzEU;6mFIomGrjxH00z0Fy>boq##9m}OMVTZGfyKlRBPtud_
zJIYYZ*~N-Jd0v8bw9yiYH|-s{63Sf}OZS}{p$F-6BO*IN<4()?jitxrY((9saAb|Z
zHxuZk+ef6eJ3$n8U60mTw(fGXGTt=o{#w7)?`%56YhWvFX{g=h>PeC*(!v?ZL+x63
z9@6=@q2lnU^d?(yMZYkG-h*=cGb$^pw%&xp@20o2R+P0XYRb2B8r!jt4=(v>fs#9i
z-(j9ITou>&u6d~IHS_^~6LlaCa&JZZL%5fxHXOzgLde|mFVeLE>W!|Ji3PNt=!#`y
z@qO_{#HaW4&m%Fu2xEF4W;W5Ah*i;c1Ib0S6JqsOv97CwpFRAqqO*$iyL%H=+_s9O
zi|7SxsG_@yo``M{8>cCKQx%&#7SP*`Ef;eO*qSvKv2D87sNy~IxIJt3nmzF<QmX`R
zr$C`u*LBA&nq$3Y74Ka|x?>I9RlM(c7`v-@|1xpcP7>A}N;h)6jOVh6TWEKYL>#3E
zx-Nd-f)pWw9N^l3%tXk&Yas_C<egOvHE`Y)AtQ`vxcfR&*rB$lZG5Y?LQ+1*hcICB
z)W)Z`yk*<b!Qaj3Wc94aPHezYbmKUBP$cv+_TW+U;~Mtzg)oSlxD$WF5dML?@lRIU
zzj2S+f)Q#MR=4ATI)H;}8i&*z?p0TDSiOcL>IOz@C3c?rw&On-;W<I6*Qn_jt+>Yh
zefS`)+N|RE5XPV=>nd&dFzHx$7{>&yZdI@21UXt@s8?~4yH>QTS8$5E82x++r*S_Y
z^pm7Lh}O4gT$_O@10OMPrv9f4e6+Uv81NQ@k|3TIEMY<X^nYnk3(itV3(jFb*CfNZ
Ikt+lDf98p08vp<R

literal 0
HcmV?d00001

diff --git a/build/classes/java/main/MQTT/PubSubExample$1.class b/build/classes/java/main/MQTT/PubSubExample$1.class
new file mode 100644
index 0000000000000000000000000000000000000000..4e867400b577c341026242f07ad2e876c516727a
GIT binary patch
literal 2409
zcmbVNYj+b>6y3K?JLz;Nr9gQqQw2<0+L4E-1yLG6QWI!NL`zYbB-eJzWG2i^3ibVd
z`~-i7E=|#{<qz<)zsKdilW8ao3(%~Ub6@A4v-dgYp84yaKmG)83P1M2#I%kPWHnsS
zaS@kvbmL7WE^El?n88~*H01kuR?u)oM?bPkTuozE#~iLHQB*snG~Q0*dK&Mf@vgc#
zuXb;wv7pAwI&R{<G~U<o0dA#X_oIwT8dVKa!-pCc1&kHjJzQ}e=|#D!z)*hKUa>9L
z_7<&T6gb}E8G+ujj^{+@1a@aSk4LWyq_Tch3T)3ip1jhim1R(}%Px0@@_xm3uiJs6
z*2!inT5>{q&Uu~;vaTJ5lFQ+IVXjoNW*g;VqkQq6U8}qD@Ns${sL3$27v=dNa8@KS
zo__?2ydNxDl0536wCeVfZ?!mCwL4L?a?&brD75UHQHXmYzwT57w8Xf;vHxO%lq096
zC<n446|BTK;Z}U|szi?O<^3=c*t;2SX({mUs#vs8RP07bE4w#^^?`=KU{$&_9;{}4
z6^@9ir!!B&nNwUZBo|BmZRu?==2YP1|F|!(tr*#r+XcIx<WMjAji4egIdPUBO4_8V
zAV%h*S8@H26;zPXlFyo3GT>m@!1Fk4;0SKBJmO*t@3>Zp(F`LdU4v_&22W}D2I{!O
zFl?<!4S|6Wky2_HSixO^JzJHg8;)C*RJ?~(fl2dPk}1<RlVpvU6K2+S-7=|h%E(K*
zYR={^Oqm)!GVn1zG4QFvau1&g^y_^J=9I}_Yo%&PE#p;UbgH$Q^NX>fY2b5wp)7nU
zAao618TcAUiPy}w3x#otM$EVvrZjwG;9Es|`-Hg#({~2G#}5J{8w|{(KxB0bet}(&
zdQK0;@@jdRbt*9a6mMrEOw3uQUA~5z?Xb3nGYgw4Iq4tjxpilh+?>bNFp@Qa9hF89
zu=l9I797`Aje*KDG?|%EchZsHvO`9h(N60EV^0CU{W|qU8O_?Ou5YuEq%xxm)9eMA
zh3Oci-(WP7x9IrREZbj1=hCjR4fWdfy7YK!V)J|6;Mf5ysXkuZ#JW{sd`%my<BHqL
ztfj@9Jp`+o@<E2;F%EjEHs`kjms8rg$7%13-^s)D*az#1tjip>&f^b2yA=tjxV3|L
z{0R~7>_9Z&gb$h+GkgOt@;f*Jf#)Cw2USzx=P||q5gg_23-QOY3tb%bvGLy^#@5jF
zGgn>6Q1(&>ID}D3BcAIR!!fRyAxtI~{-(tq?s@Czp1+UO8hV=Oy|NB%{#X;~HS|rT
zeu2J@{`oZ+W4}T)v2AF8;y$)FG1$b8p&_m&)b>t_aW&aRu`i`&yD4aBxQRVOdpU1n
zUlaQupxjTKAh!XsJ3wYPiFcV}jaU`(Q!R7}a^i$VO~uS(e2$ar0B+#~_qut%h?AV9
zczy~mB@CCjRxvu!N#g(k5${0-^cjjarL8FS*un(;O~$B(TNc}>PT(|NraysK@M_{W
zO8i>mzvEefpOEPUaOlxayW<27kP_&!kMt%<NQI;2*lIhrFoiR8c$R0~5R(+IaoUA*
Uc%5SkZ{R$}In$|Ras<-<0*pIWtN;K2

literal 0
HcmV?d00001

diff --git a/build/classes/java/main/MQTT/PubSubExample.class b/build/classes/java/main/MQTT/PubSubExample.class
new file mode 100644
index 0000000000000000000000000000000000000000..8658736e28e1f6ef4c6c3aaaff7b4894adc62222
GIT binary patch
literal 3789
zcma)9`F9&f9si6hdDrW8oXBw!C4p>6OJqB-8q$PBX+v!%X>IJ-iQE*`Kv~O+ys@NJ
zc2|jAC~Y7V%2AHCQ0}8ZIl_?uvZ;G<L%Hv>JpKdT<41Up@|l%lTe9KF&z{-&-uH~3
z`_B_k1Go`?)6fT7#aRt1W>n-9<W&?@I0}jqc20q-L4z$9uLV9z3eIa-Cn4)_LB*`x
z=QP}nH%Nvzs<=nPn{cmO?vuES3f`<ChPO!cB^7U#`~523rs3^)K*c*0yi=p#cWKy(
zcgtl?!Gjtic#nqb@m{&SPsRIHJR~_ER`H064=DJcwB}I_z4(w^J}i+RQSea}AJecO
zAD6m6q2iPB@F^9amiuEWJ|p+fO62EMJT4EPSMUV|Ulh;>3kAy^$eEsJc>>Kh*#+A_
zD$o?~IwKGsaHcGQ_F=nVoh;=iEqC0U%n=eDb~0w}jOp6)Tm^>xX`3=O4v(A~A5V;x
zCR3%!<FjVIn6r*hR^GG=0-NF!!)ML&W+G=6vWb-M+J)>9sY}f`g~Djjr-c2(j+;$b
znVenptVGeAb`t!y3VtGg&iBvnPmFLIAi0(C$zeMMj|!BcIhS+HDQVp*4MgWH&oi?$
zeorIfM=I1(ZpO*y%>w0iROFU?JC{ghOc^=in=7^n^fV%OAaI0ip*&6LZG`3cY{m+_
zBv;sUvy4#38bPEblddykxiXf4mO<LA7E6=kPSMT?w0YIfKG!wp1X_7M<#^RoXkw5O
zNKKG{;Gr$$o0*vrvl!%8L7JVS;4apifR=JfZpJ!c2h~uM>s}dr9RoPVTJST)WFnE1
z)iUjPesbTTL;H1n376@^w3D|Io>lN1*GuG0&zGjJuTLG*Swon!v(vu7h8m!6<%<Gc
zjg(Cg8EM{^1@<+<P*Z0*zJjkR_?nI@xGJ!@-rD|>otv^;9bd;c=%P`rQWm+<A0)@n
z@l9M-P}VVz1s&hQ6U@XlI%~>Mu&ConJf-7lJR{{i%P_9)sO$DgA1L74_>RC1gT3Zu
zTzgV#>h0|{_8Q~Uu4PUcV}r+%RQg?fPhiUu85Q{se_0rwk)+b^OS^s`u(eX4hU`YR
z7wJsj@a?>nG?<CNUGH2jF;0l*v$u8pP?|Y_9|?3f5YB2}>G(08lWafH@l*UvpwnOx
z<!o<SI#6v@sWL3R(eZQqLSUy+<u+KRl9txh`YEtmGrGIG4P(q@0~@B{vU8ohF=Ne1
zhpk!L5AYf*C~#(FGwb*zekG0iwT|E5vX0-%8s5`@S4%C*alxp2PJto+9eywK_Xj!q
zyet8Klw}`gGw}OQ^1C@>mOP86KjSZw^sfY2vfBxIUh0mnPJB&^j82|qk_gIL97d*Z
zRk9}=e`CCBtueSez8bn3A_sE2XZZs;%PgcANzPcB9=}r}R<`IIyEf13!YR>;&Wa%0
zNsMu<`yB3;nU@pNEEX*}K=-bpe6^L;9wMXaJCz%PtrTRdR<xY?Qc;e!b*?3v#&UWG
zg)DF|-pH`6yH@J_t@IQ}W2WS~ypXP)YlB^Z(*8)+@?|b~n+^$Vj}QGnXIo{w&0KDh
zLs#I2#;mQ<2RCR7=Xo##c(H6*>zbVyTy`g@`(X5Q+V8HRt`yag)wa^34c8oJ|Bu)?
zHlZwwAt_g-v;A|vd`5)hT@(FuKR(efG0pTWxK+aOzyhV(z5;z~WUY}bRp&t9c1S)e
zmP>E2P%JH%-j=EY7S2jUU~j>i_2tWkx7n2KE!9aI{Wu-;aOL&G<nc1xPSaQQ$#SJ?
zWU3m)TIC^lAlY|YQ%g`8p8?tLyf$ijljY)EknbqQx28k>XCjvMwg(LmT-4*PnX&kk
zyoK*u`4fWRC_BdWI8O=gf_tQU9^y)XKEbs)0BX3E-+F}rw_%W{77XE)gpj$Z#Fwc~
ziCd$gkp(oJjE0lp$Ww@<o1)FBbU3P{l99-hTDmDbnhr-slg*KX$|BVCp1t#E8D4~z
zo=0m^jj7=>^s8uF#5zLS_m;6fx`E3c{*@6eqoXILma(ypq?70cY${`O8C$A!i-@Hu
zeQO!p>ZrG`K^=?4n#*`m9p#Hj8H+4n$CCQ0VNrvSMeIy3;3f0eRmOD{ie$?ou208W
z%6REKb|<x%)~S>cuM^uP#gb-yw7bF<_!W+6W%SgMO2_LwBSn;f=~zT>`YIChxFOjZ
zYb|5n9X(~d>~TDrRF{QBZ<M+ivIAuttVCu7^5s?Jp(Qg`AP-lO$+eJ2s>qwlxOtV>
zqg7-TBh|m+3M-{YTojl1&qWhtWj%;pT-$hB2L<hD#d>VR2E-9X4?1xGn{X7HS)f~C
z5|hPtJb)c|1c&%CI*ezK#NTnV5I8E@af{f5K5-cRq7MTigA-x~w~7n6P27VaaS^vu
z^GR_(M#W<o6VKw5cpj(4zmN)T#CRx%JAw+oM0<{k0SsdVDka~ClNdz{<+~WeDQJ|a
z;WSdT_JA10IBtia)Q50}5>(j%coow0t0}Y@cak>*CDeflel?*r)Q(s4D~xU81-yoI
z5yZtm@mk!)KI;+x!0YI#f=Tl4Lg)pWtSZP5GIi}Yqk!W<D0uz9@i2vFNgBd5`nhWi
Jaf~~l{uhuN{xSdn

literal 0
HcmV?d00001

diff --git a/build/classes/java/main/MQTT/SubExample$1.class b/build/classes/java/main/MQTT/SubExample$1.class
index 422a3084ea496af76cf141b8d53de8b49cf03b90..b6ea4436ec69cb76ba063ed13c89f725ea28f5e5 100644
GIT binary patch
delta 1048
zcmY*XX;KqG6#hEf49x%`B8Y5*f<j1$Ac%q+vM2}$62%BELo$SfERalMP&DcR{F9U5
zGEh?G0W1&U1w4Y5uM;FVRr9^2yWji1*Zr&JM{WN5pReBl4B&kQ+HjLY#i)c^9Ag;g
zuwp{Mq=efXcQC~vVY-6W?n;>9sKls%Ss8O2_b@MDL1gaBSd`(H@j%8yadJsyAIS&^
zJIV1F%Q9AExSnu4#WNYtC1?^>B?NbOmMkkF1v=IgoWWTI9SAeHqFPq-rMF@}e<ZG_
z4K2PYVO>E4QL$q~K@4#QXK`ChON4!kMk<mBOGqe4VpD9|QjkKr;IlS63}hI33k%jd
zpXyb|v{-Ca3vQ6>Ur*^;NS&V=A66w~6}&)B!M5mP;3Y$4LAMU&UtveYuNfGZ@J2x%
zoebx>>UO(Tbv~u1)2gPXv_vQwS2y%+)kvy(E@BkdIYWawmP{n{pb<$XV#&18t_HPC
zS|671R>3<Vq{gfM$AzJGcERuWEoN3Ha-V)%b8O<6))H%ms$eFS(i6tNxUQ>vraX~S
zc7(wm){UtULvz=3Az=TIZ=-8xXa{pT#mMPF*y!&-CuPqSpN9n&vfSPC1<bt%%PvJ0
zoF{b99-s+bgi6up=td7k3?6t7EBvI2cFJWBU=8fUwg<Zj$J_y=fX6JXIa>1js4?L*
zQR{M<sPfY9IziAQoH~L=oA6E&cudrrXmFh(-$bK{(;vZIO=QcgTIr>NUUW4nYa(SU
zq$Nr=PMkBuPp};*F)Fdm3v%cs@j^}(K3pJy)mTR#<*Za>8U5thX#FA`Ee$40u^3E0
zF*rbFU=ND>Gnio7OhDvYgx^YVq_0G|OqCZa<UQ2LTjW(=DtS0XDvm*1qJ|7ZxO~`n
ukeZ6dtX!vb5q-x>u%i+TS1?RRtr#gDyozgNZMcpbaFfST!Dw3Ilm7zh9<Q1J

delta 844
zcmYk5+foxj5Qe`=0=o>WKoAfFvQb1yf<Xa6#RKA5LBx27q8MO>U`QZ|ly|xE3F1q5
ziHBfGl@DNf<$L%FmOX(2FZS=A?ti-f?y3FN^rxZp^Y8Z`z!3R5I=G-Y!kEQH%_S~t
z{9G|GZgEvJ!8MJ=^*YJju(+wIXUxDYo7*;bZ0_3JGrUO?owB)a?6_u{2R1V{4>buM
zSv<CQV)0brY<@`iMv@NCc<#_ew?l|oMQ|mxk%|}AGx0=v)hiTJt7{f799}YK7_S^s
z%$Gy{mgWVAMLZLH?XbkMqOIIr+t%rjW<?QlXS@Y3z2PmoDR<H<6jDoGxct#Sl6XVL
za8?ycTVx$_xQeiLBaw*fPUnT|=Dp(EeAX@IT<=}FSj}iflRJ^iX1#@CI+xAl3dOK%
zvF5PO{O6g#dsQB-&6hf4kBUxIW1|^MHXM*Ige%c-b>BXGVs#|?6&2aSw<#wdM+Iwz
zgD{T?I#plOL$90^Cpal+D*Tp;HDZ^y@h86#*rKLF?bJ3_GFB<~SzV?63I~D>0#V~M
z3bY4|*CY_D5UkJ~JS2XFmI|$((7`sb`#QSiv60RPIWE)mGDU=0v2#Ra)3K_)p&bpo
z`a}(VGOf|SToQUzMmi{u8<U`4icHckUO)(^i0=+ED;cwj9#ODOeR2yY@&#p-9u^Ss
z?Rz5k#p&vuxQH023TfS`u_vU5%mAmQh2ji@yRC+$jcKL!>+CFh@V^>ruZEJ}Vpy*F
YIa|Fr!l>8)=QuAbk;ju<hgh)x0aHkIiU0rr

diff --git a/build/classes/java/main/MQTT/SubExample.class b/build/classes/java/main/MQTT/SubExample.class
index f6979cd01c6c2ab757c964a759badc497bb8c6b4..e9d6c1c60121338547706aa087b5f56dd7a1f6a7 100644
GIT binary patch
delta 1373
zcmZuxZBrXn6n<{9yLZ_vNCTwAg53(XV1X2C8BAZG1Ztt+SV1vTt6{T-l#rxJp!kYa
z)H;rqdbQU2+WLak8E33BOUI0kAJy@rpB%>-r+)I2{sHw|NR`QScK6(K&-0w;oISI9
zmjb^B7Jm5qt8W0@j?WD2z+oNt7*H{)V~pco>E6dNZh+&kH1}5^iU&9*4ESWkha);3
zl<QFg58+{%5YsVfz(!meM`Dj~Bn$*FCE=uwV{)C=k<u|b!;zMv83T>TN^@MIIgY%J
zf`OYcD<$T1oRFJ&9goWOF&&S~^$7_+spBcRS>Sk@<K&qiUldC$=Fx01!FGwi*ahVo
zk`re=%{v%s3wAaf3Z*i3EH#zM7s8$0-8)S@i$#X2smzQM$~)<NCYKL2F|>-K-ex0}
zbkYSAx8XT4;qB6%#|s>%#A)x=u^KCqNv9pVkW446zFcP7$yp{|#v;cnCQf6?#2LKG
z5WL27;#RvgHkET?aqI5E{;<U%OuUBIO`OFWCSJlh@r$?qASJ$u^9-A<(b>tool8#2
z3LPCCW$7l~!rKh>|Iw&GAwzdIY3Hr5B|4Sfx_9ud?EXCy?_<%#1?*&Kqc>|3pDT4e
z7x96t`yqoelTT3lAIVWDG$8UnmcC}kX7dj1mhp+CUZRjQZ#!8EeJVWa-s*&tc5<<T
z6ImVAU|h6mL9whx#6GoC{Gs-XjM^;*w8)|AW3jndC>2X5LTgiCsI+HuIU4Y_eQitY
za5-x?gPL#(gK-9LOY0CrL(7nu<_+SMcInFjZn1?$D9{0R!tWWm0`FaZC9J4jY7uI*
zt$hXBa1lJZ0zIq+HN{26Wf(>HC}Os|sPtEnX`{!*4KAv;2Q?QP$|!z<ub{?7t&6%6
zuZTdD)Hk{ds4t@juR{+ib*hUS%b1&p8Kj;{#R>H{P!mNoMla*06>JXkAa`MnZ+Ed}
z8Rx><{{sFdnXFO$W*4`tb+r!Nx`txgdiBzK`&&w2>-E4}OCZ&xxyYfcla(WrBPt=Q
z^*g=*{XqB?ztNxQ#V$Hj(%3}SM>~_wj!N>X=-PmK_^|~w*hXhUKQ>~BA}Qj|(=l|O
zGB2VF-{KB@hcJG^Zv2crq&q;$`*0OK4CrNz*w4b~W8;Xh<LF;tb2vz8z!6lC_}7%S
z2O6at*h^`gN_>wV^iq>oA+R5Pgwp4N2(<usS%C^1fCrpqaVL3R_*jZG5738I#gZ7L
hHdP!VZX-PZP%j$CFzJr0-pU9A6Mq^(9v}vw{|o6#D@gzV

delta 1339
zcmZux+jA3D9R5zSw{FtgHZ4tQB_Kj8kfbV1jkZ)$E&@d^3WlOJN!N5~k`37n)}jWl
z=s05WpccFWUdBgpW;;V>c;U?#9cT2-7e~iGz(*PNcY3iI$4T<LobNl|ch1?f`L$!V
zqx$V%H*NyB51;FZ<4^+*<A{bwbv%Zn8jfjrTtiC5aUB}QRGiSE<B$kXsCZIGqi7m2
zuHh+>(}I@KkX13EBLq|QPix3&m=vX@;iQHs6?tJ)&@tMLqK<CZ0xgMfN<~?NqhlRh
zAz9IIS~SmSm=^h24KpI25#Vzgo)^svDyk~ZUije+MK7Fk-6X%sw(>ES=6|p&(u*X?
z=X~pl@=_2l;}wRkBbAJkEn6A09I=X)Yo+tnj8)7<qfr&F2JsrsF@)S~DG`h1?QA+f
zX*+JBe_-HV2F0ml#^e1Akx9E?#vHTg*kvb{F(=BlU5L46p=6fRZl!E8^x5TH%*^Jk
zl4HjBl+wvt{0-9U4E=mu>E}oN8#Xpal6J9ZW?iz6xOOCnw{Sj)w=v70FJtBe|K8s@
zcrJ(wc!!~FdHG@vshdSN!VnPCUAtsu6Qsg%Q4B3JNg*x`x4(<`g186o2QepHF5z+z
zAMmr%;PwykQ4nw9V+N_<<VfHXoTr+0PxYswR<h}eV^VhoR|WMN4VlwfvqVFm@!QfM
z|3Z%QE@gmc<Rt$|9`T2I`}jd$h#yvx{I>Fy5wM)4&6*Po{@%Xh-&|AIvFa=&dh}pt
zuES^eJxGSU-%v&k^?<ZZszFO_+B}bjgj|E3nnxg^gcZp{kk~ae(n!;056wmkg-!JH
z&`J_vIjndv{=;dj!)pkoNVnaqqGN?-tRl*SUMCe>>iApQ$uzveTp)G*OCZ2lO~y5J
zr>>)C9(N?vu<BvWv9RnRatWHqYrn)?LS7Lu?(|S?7RY)JcP%cx4&6ZV0^C?{v$ScW
zcM0tKKk)7)kWPdaDo&(MR%}biE+SPrEDzDIL3bX%;5T}s{Mbr=3#ZXTv5}rl69Q<a
z*n(F2gwT#P=s+)4A&M^S!)kh;yD^0brZIraxF1)MKn)M#76$PhhVUb{<7W(${=?+3
z1HU85B#f}N*jZ&m*u}=Mn^mxf&0sIKk?jdIkjX7PKq4|(-5{YMC?wWKQo~S5g5x2Q
zlEu|Q5+gJ#z)IMOU9^=ZR={qmd}w7Sv4<)@LM%u2d+ECEBW@4;f75#8xQhKMMi;*f
a*rDRUpSVafA0d_x2hmSiUpO8rp#1|&e;^tF

diff --git a/build/classes/java/main/REST/services/HelloWorld.class b/build/classes/java/main/REST/services/HelloWorld.class
index bd8e42a79689108dc9a22567812893d8651a6a35..28af175c95edacd5c4990d038abd8c2d32ba7bca 100644
GIT binary patch
delta 35
pcmZqUYUA3_%*@C)Ih93o@>*tlMzP6nnadevf&3swwaGhJ`~bSn3Qhn3

delta 35
pcmZqUYUA3_%*@C?Ih93o@>*tlMv2L9nadd!fczjv&B;4h`~bT<3ReIC

diff --git a/build/classes/java/main/REST/services/UsersService.class b/build/classes/java/main/REST/services/UsersService.class
index 4103f648bc2e124aa6dd4cb4c8f1799cb3f9cbf0..57372452ad74121755537da309603cb23f4d3f5f 100644
GIT binary patch
delta 41
xcmaFB_keH1Syo1|$>&%TSmhbm85AZPvo-T-FmNzvGVm~HF^DkeOg_vu7Xa)<39A4A

delta 41
xcmaFB_keH1Syo2z$>&%TSQQx985AcQvo-T-GH@_xG4L>GGl($gPCm>w7Xa+U39<kH

diff --git a/build/tmp/compileJava/source-classes-mapping.txt b/build/tmp/compileJava/source-classes-mapping.txt
index 24efb49..45d5820 100644
--- a/build/tmp/compileJava/source-classes-mapping.txt
+++ b/build/tmp/compileJava/source-classes-mapping.txt
@@ -1,13 +1,19 @@
 REST/beans/User.java
  REST.beans.User
+MQTT/PubSubExample.java
+ MQTT.PubSubExample
+ MQTT.PubSubExample$1
+REST/beans/Users.java
+ REST.beans.Users
+REST/StartServer.java
+ REST.StartServer
+MQTT/PubExampleCallback.java
+ MQTT.PubExampleCallback
+ MQTT.PubExampleCallback$1
 REST/services/HelloWorld.java
  REST.services.HelloWorld
 REST/services/UsersService.java
  REST.services.UsersService
-REST/StartServer.java
- REST.StartServer
-REST/beans/Users.java
- REST.beans.Users
 MQTT/PubExample.java
  MQTT.PubExample
 MQTT/SubExample.java
diff --git a/src/main/java/MQTT/PubExample.java b/src/main/java/MQTT/PubExample.java
new file mode 100644
index 0000000..666b229
--- /dev/null
+++ b/src/main/java/MQTT/PubExample.java
@@ -0,0 +1,51 @@
+package MQTT;
+
+import org.eclipse.paho.client.mqttv3.*;
+
+public class PubExample {
+    public static void main(String[] args) {
+        MqttClient client;
+        String broker = "tcp://localhost:1883";
+        String clientId = MqttClient.generateClientId();
+        String topic = "home/sensors/light";
+        int qos = 2;
+
+        try {
+            client = new MqttClient(broker, clientId);
+            MqttConnectOptions connOpts = new MqttConnectOptions();
+            connOpts.setCleanSession(true);
+            //connOpts.setUserName(username); // optional
+            //connOpts.setPassword(password.toCharArray()); // optional
+            //connOpts.setWill("this/is/a/topic","will message".getBytes(),1,false);  // optional
+            //connOpts.setKeepAliveInterval(60);  // optional
+
+            // Connect the client
+            System.out.println(clientId + " Connecting Broker " + broker);
+            client.connect(connOpts);
+            System.out.println(clientId + " Connected");
+
+            String payload = String.valueOf(0 + (Math.random() * 10)); // create a random number between 0 and 10
+            MqttMessage message = new MqttMessage(payload.getBytes());
+
+            // Set the QoS on the Message
+            message.setQos(qos);
+            System.out.println(clientId + " Publishing message: " + payload + " ...");
+            client.publish(topic, message);
+            System.out.println(clientId + " Message published");
+
+            if (client.isConnected())
+                client.disconnect();
+            System.out.println("Publisher " + clientId + " disconnected");
+
+
+
+        } catch (MqttException me ) {
+            System.out.println("reason " + me.getReasonCode());
+            System.out.println("msg " + me.getMessage());
+            System.out.println("loc " + me.getLocalizedMessage());
+            System.out.println("cause " + me.getCause());
+            System.out.println("excep " + me);
+            me.printStackTrace();
+        }
+    }
+}
diff --git a/src/main/java/MQTT/PubExampleCallback.java b/src/main/java/MQTT/PubExampleCallback.java
new file mode 100644
index 0000000..403a22e
--- /dev/null
+++ b/src/main/java/MQTT/PubExampleCallback.java
@@ -0,0 +1,68 @@
+package MQTT;
+
+import org.eclipse.paho.client.mqttv3.*;
+
+public class PubExampleCallback {
+    public static void main(String[] args) {
+        MqttClient client;
+        String broker = "tcp://localhost:1883";
+        String clientId = MqttClient.generateClientId();
+        String topic = "home/sensors/temp";
+        int qos = 2;
+
+        try {
+            client = new MqttClient(broker, clientId);
+            MqttConnectOptions connOpts = new MqttConnectOptions();
+            connOpts.setCleanSession(true);
+
+            // Connect the client
+            System.out.println(clientId + " Connecting Broker " + broker);
+            client.connect(connOpts);
+            System.out.println(clientId + " Connected - Thread PID: " + Thread.currentThread().getId());
+
+            // Callback
+            client.setCallback(new MqttCallback() {
+                public void messageArrived(String topic, MqttMessage message) {
+                    // Not used Here
+                }
+
+                public void connectionLost(Throwable cause) {
+                    System.out.println(clientId + " Connectionlost! cause:" + cause.getMessage());
+                }
+
+                public void deliveryComplete(IMqttDeliveryToken token) {
+                    // Until the delivery is completed, messages with QoS 1 or 2 are retained from the client
+                    // Delivery for a message is completed when all acknowledgments have been received
+                    // When the callback returns from deliveryComplete to the main thread, the client removes the retained messages with QoS 1 or 2.
+                    if (token.isComplete()) {
+                        System.out.println(clientId + " Message delivered - Thread PID: " + Thread.currentThread().getId());
+                    }
+                }
+            });
+
+
+            String payload = String.valueOf(0 + (Math.random() * 10)); // create a random number between 0 and 10
+            MqttMessage message = new MqttMessage(payload.getBytes());
+
+            // Set the QoS on the Message
+            message.setQos(qos);
+            System.out.println(clientId + " Publishing message: " + payload + " ...");
+            client.publish(topic, message);
+            System.out.println(clientId + " Message published - Thread PID: " + Thread.currentThread().getId());
+
+            if (client.isConnected())
+                client.disconnect();
+            System.out.println("Publisher " + clientId + " disconnected - Thread PID: " + Thread.currentThread().getId());
+
+
+
+        } catch (MqttException me ) {
+            System.out.println("reason " + me.getReasonCode());
+            System.out.println("msg " + me.getMessage());
+            System.out.println("loc " + me.getLocalizedMessage());
+            System.out.println("cause " + me.getCause());
+            System.out.println("excep " + me);
+            me.printStackTrace();
+        }
+    }
+}
diff --git a/src/main/java/MQTT/PubSubExample.java b/src/main/java/MQTT/PubSubExample.java
new file mode 100644
index 0000000..d3b61d9
--- /dev/null
+++ b/src/main/java/MQTT/PubSubExample.java
@@ -0,0 +1,91 @@
+package MQTT;
+
+import org.eclipse.paho.client.mqttv3.*;
+
+import java.sql.Timestamp;
+import java.util.Arrays;
+import java.util.Scanner;
+
+
+public class PubSubExample {
+    public static void main(String[] args) {
+        MqttClient client;
+        String broker = "tcp://localhost:1883";
+        String clientId = MqttClient.generateClientId();
+        String pubTopic = "home/sensors/master";
+        String subTopicArray  [] = new String[] {"home/sensors/light", "home/sensors/temp"};
+        int subQosArray [] = new int[] {1,2};
+        int pubQos = 2;
+
+        try {
+            client = new MqttClient(broker, clientId);
+            MqttConnectOptions connOpts = new MqttConnectOptions();
+            connOpts.setCleanSession(true); // false = the broker stores all subscriptions for the client and all missed messages for the client that subscribed with a Qos level 1 or 2
+
+            // Connect the client
+            System.out.println(clientId + " Connecting Broker " + broker);
+            client.connect(connOpts);
+            System.out.println(clientId + " Connected " + Thread.currentThread().getId());
+
+            // Callback
+            client.setCallback(new MqttCallback() {
+
+                public void messageArrived(String topic, MqttMessage message) {
+                    // Called when a message arrives from the server that matches any subscription made by the client
+                    String time = new Timestamp(System.currentTimeMillis()).toString();
+                    String receivedMessage = new String(message.getPayload());
+                    System.out.println(clientId +" Received a Message! - Callback - Thread PID: " + Thread.currentThread().getId() +
+                            "\n\tTime:    " + time +
+                            "\n\tTopic:   " + topic +
+                            "\n\tMessage: " + receivedMessage +
+                            "\n\tQoS:     " + message.getQos() + "\n");
+
+                    System.out.println("\n ***  Press a random key to exit *** \n");
+                }
+
+                public void connectionLost(Throwable cause) {
+                    System.out.println(clientId + " Connectionlost! cause:" + cause.getMessage()+ "-  Thread PID: " + Thread.currentThread().getId());
+                }
+
+                public void deliveryComplete(IMqttDeliveryToken token) {
+                    if (token.isComplete()) {
+                        System.out.println(clientId + " Message delivered - Thread PID: " + Thread.currentThread().getId());
+                    }
+                }
+
+            });
+
+            System.out.println(clientId + " Subscribing ... - Thread PID: " + Thread.currentThread().getId());
+            client.subscribe(subTopicArray,subQosArray);
+            System.out.println(clientId + " Subscribed to topics : " +  Arrays.toString(subTopicArray));
+
+
+            String payload = "Client connected at time: " + new Timestamp(System.currentTimeMillis()).toString();
+            MqttMessage message = new MqttMessage(payload.getBytes());
+            // Set the QoS on the Message
+            message.setQos(pubQos);
+            System.out.println(clientId + " Publishing message: " + payload + " ...");
+            client.publish(pubTopic, message);
+            System.out.println(clientId + " Message published - Thread PID: " + Thread.currentThread().getId());
+
+
+            System.out.println("\n ***  Press a random key to exit *** \n");
+            Scanner command = new Scanner(System.in);
+            command.nextLine();
+
+            client.disconnect();
+
+
+
+        } catch (MqttException me ) {
+            System.out.println("reason " + me.getReasonCode());
+            System.out.println("msg " + me.getMessage());
+            System.out.println("loc " + me.getLocalizedMessage());
+            System.out.println("cause " + me.getCause());
+            System.out.println("excep " + me);
+            me.printStackTrace();
+        }
+
+    }
+
+}
diff --git a/src/main/java/MQTT/SubExample.java b/src/main/java/MQTT/SubExample.java
new file mode 100644
index 0000000..73e23ca
--- /dev/null
+++ b/src/main/java/MQTT/SubExample.java
@@ -0,0 +1,75 @@
+package MQTT;
+
+import org.eclipse.paho.client.mqttv3.*;
+
+import java.sql.Timestamp;
+import java.util.Scanner;
+
+public class SubExample {
+    public static void main(String[] args) {
+        MqttClient client;
+        String broker = "tcp://localhost:1883";
+        String clientId = MqttClient.generateClientId();
+        String topic = "home/sensors/#";
+        int qos = 2;
+
+        try {
+            client = new MqttClient(broker, clientId);
+            MqttConnectOptions connOpts = new MqttConnectOptions();
+            connOpts.setCleanSession(true);
+
+            // Connect the client
+            System.out.println(clientId + " Connecting Broker " + broker);
+            client.connect(connOpts);
+            System.out.println(clientId + " Connected - Thread PID: " + Thread.currentThread().getId());
+
+            // Callback
+            client.setCallback(new MqttCallback() {
+
+                public void messageArrived(String topic, MqttMessage message) {
+                    // Called when a message arrives from the server that matches any subscription made by the client
+                    String time = new Timestamp(System.currentTimeMillis()).toString();
+                    String receivedMessage = new String(message.getPayload());
+                    System.out.println(clientId +" Received a Message! - Callback - Thread PID: " + Thread.currentThread().getId() +
+                            "\n\tTime:    " + time +
+                            "\n\tTopic:   " + topic +
+                            "\n\tMessage: " + receivedMessage +
+                            "\n\tQoS:     " + message.getQos() + "\n");
+
+                    System.out.println("\n ***  Press a random key to exit *** \n");
+
+                }
+
+                public void connectionLost(Throwable cause) {
+                    System.out.println(clientId + " Connectionlost! cause:" + cause.getMessage()+ "-  Thread PID: " + Thread.currentThread().getId());
+                }
+
+                public void deliveryComplete(IMqttDeliveryToken token) {
+                    // Not used here
+                }
+
+            });
+            System.out.println(clientId + " Subscribing ... - Thread PID: " + Thread.currentThread().getId());
+            client.subscribe(topic,qos);
+            System.out.println(clientId + " Subscribed to topics : " + topic);
+
+
+            System.out.println("\n ***  Press a random key to exit *** \n");
+            Scanner command = new Scanner(System.in);
+            command.nextLine();
+            client.disconnect();
+
+        } catch (MqttException me ) {
+            System.out.println("reason " + me.getReasonCode());
+            System.out.println("msg " + me.getMessage());
+            System.out.println("loc " + me.getLocalizedMessage());
+            System.out.println("cause " + me.getCause());
+            System.out.println("excep " + me);
+            me.printStackTrace();
+        }
+
+
+    }
+
+
+}
diff --git a/src/main/java/REST/services/HelloWorld.java b/src/main/java/REST/services/HelloWorld.java
index 182441d..e7e3163 100644
--- a/src/main/java/REST/services/HelloWorld.java
+++ b/src/main/java/REST/services/HelloWorld.java
@@ -11,14 +11,12 @@ public class HelloWorld {
     @GET
     @Produces("text/plain")
     public String helloWorld(){
-
         return "Hello world!";
-
     }
 
     @GET
     @Path("{name}")
-    @Produces("text/plain")
+    @Produces({"text/plain"})
     public String helloWorldName(@PathParam("name") String name){
 
         return "Hello, "+name+"!";
@@ -28,7 +26,6 @@ public class HelloWorld {
     @GET
     @Produces("application/json")
     public String helloWorld2(){
-
         return "{\"message\": \"helloWorld\"}";
 
     }
diff --git a/src/main/java/REST/services/UsersService.java b/src/main/java/REST/services/UsersService.java
index 51fffb7..89c24e2 100644
--- a/src/main/java/REST/services/UsersService.java
+++ b/src/main/java/REST/services/UsersService.java
@@ -19,7 +19,6 @@ public class UsersService {
     @GET
     @Produces({"application/json", "application/xml"})
     public Response getUsersList(){
-
         return Response.ok(Users.getInstance()).build();
 
     }
@@ -33,7 +32,7 @@ public class UsersService {
         return Response.ok().build();
     }
 
-    //permette di prelevare con un determinato nome
+    //permette di prelevare un utente con un determinato nome
     @Path("get/{name}")
     @GET
     @Produces({"application/json", "application/xml"})
-- 
2.18.1