example3.js

var dt = require('./dt.js');
var process = require('process');

// connects to example2
var dt_node = new dt({port: 10001, key: 'asdf_any_length', nodes: ['127.0.0.1:10000']});

dt_node.emitter.addListener('started', function() {
	console.log('distributed table "started" event');
});

dt_node.emitter.addListener('object_added', function(object) {

	console.log('dt object_added event', object)

});

dt_node.emitter.addListener('object_removed', function(object) {

	console.log('dt object_removed event', object)

});

dt_node.emitter.addListener('message_received', function(m) {

	console.log('dt message_received event', m);

});

// send a message every 5 seconds
setInterval(function() {

	console.log('sending message to all nodes');
	dt_node.send_message({some_key: 'an object is a nice message format if amongst online nodes'});

}, 500);