arg/scriptcraft
Archived
3
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

fix code in sc-mqtt module

Browse source
This commit is contained in:
walterhiggins 2014-02-04 21:04:12 +00:00
parent 349c2f17cf
commit fe62f61883
2 changed files with 26 additions and 48 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
docs/API-Reference.md
View file

@ -869,27 +869,16 @@ present in the CraftBukkit classpath. To use this module, you should
messages to/from a Net-enabled Arduino or any other device which uses messages to/from a Net-enabled Arduino or any other device which uses
the [MQTT protocol][mqtt] the [MQTT protocol][mqtt]
var mqtt = require('sc-mqtt'); var mqtt = require('sc-mqtt');
// create a new client // create a new client
var client = mqtt.client( 'tcp://localhost:1883', 'uniqueClientId' ); var client = mqtt.client( 'tcp://localhost:1883', 'uniqueClientId' );
// connect to the broker // connect to the broker
client.connect( { keepAliveInterval: 15 } ); client.connect( { keepAliveInterval: 15 } );
// publish a message to the broker // publish a message to the broker
client.publish( 'minecraft', 'loaded' ); client.publish( 'minecraft', 'loaded' );
// subscribe to messages on 'arduino' topic // subscribe to messages on 'arduino' topic
client.subscribe( 'arduino' ); client.subscribe( 'arduino' );
// do something when an incoming message arrives... // do something when an incoming message arrives...
client.onMessageArrived( function( topic, message ) { client.onMessageArrived( function( topic, message ) {
console.log( 'Message arrived: topic=' + topic + ', message=' + message ); console.log( 'Message arrived: topic=' + topic + ', message=' + message );
}); });

11
src/main/js/modules/sc-mqtt.js
View file

@ -29,27 +29,16 @@ present in the CraftBukkit classpath. To use this module, you should
messages to/from a Net-enabled Arduino or any other device which uses messages to/from a Net-enabled Arduino or any other device which uses
the [MQTT protocol][mqtt] the [MQTT protocol][mqtt]
var mqtt = require('sc-mqtt'); var mqtt = require('sc-mqtt');
// create a new client // create a new client
var client = mqtt.client( 'tcp://localhost:1883', 'uniqueClientId' ); var client = mqtt.client( 'tcp://localhost:1883', 'uniqueClientId' );
// connect to the broker // connect to the broker
client.connect( { keepAliveInterval: 15 } ); client.connect( { keepAliveInterval: 15 } );
// publish a message to the broker // publish a message to the broker
client.publish( 'minecraft', 'loaded' ); client.publish( 'minecraft', 'loaded' );
// subscribe to messages on 'arduino' topic // subscribe to messages on 'arduino' topic
client.subscribe( 'arduino' ); client.subscribe( 'arduino' );
// do something when an incoming message arrives... // do something when an incoming message arrives...
client.onMessageArrived( function( topic, message ) { client.onMessageArrived( function( topic, message ) {
console.log( 'Message arrived: topic=' + topic + ', message=' + message ); console.log( 'Message arrived: topic=' + topic + ', message=' + message );
}); });