File tree 2 files changed +4
-4
lines changed
2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -18,14 +18,14 @@ class Hub {
18
18
}
19
19
} )
20
20
this . client . on ( 'message' , ( topic , message ) => {
21
- this . handlers [ topic ] ( message . toString ( ) )
21
+ this . handlers [ topic ] ( message )
22
22
} )
23
23
// this.client.on('end', () => {
24
24
// })
25
25
}
26
26
27
27
publish ( topic , message ) {
28
- this . client . publish ( topic , message )
28
+ this . client . publish ( ` ${ this . accountID } / ${ topic } ` , message )
29
29
}
30
30
31
31
subscribe ( topic , handler ) {
@@ -35,7 +35,7 @@ class Hub {
35
35
}
36
36
37
37
unsubscribe ( self , topic ) {
38
- this . client . unsubscribe ( topic )
38
+ this . client . unsubscribe ( ` ${ this . accountID } / ${ topic } ` )
39
39
}
40
40
41
41
disconnect ( self ) {
Original file line number Diff line number Diff line change 1
1
{
2
2
"name" : " labstack" ,
3
- "version" : " 0.31.6 " ,
3
+ "version" : " 0.31.8 " ,
4
4
"description" : " Official Node.js client library for the LabStack platform" ,
5
5
"main" : " index.js" ,
6
6
"scripts" : {
You can’t perform that action at this time.
0 commit comments