lib/rebus.js
function _publish(obj, callback) {
      // Write the object to the separate file.
      var shortname = prop + '.json';
      var data = JSON.stringify(obj);
      var hash = _checkNewHash(shortname, data);
      if (!hash) {
        // No need to publish if the data is the same.
        return callback();
      }
      published[shortname] = true;
      // Update new object and call notifications.
      _updateObject(shortname, obj, hash);
      var fullname = path.join(folder, shortname);
      fs.writeFile(fullname, data, function (err) {
        if (err) {
          console.error('Failed to write file %s err:', fullname, err);
        }
        return callback(err);
      });
    }
function _publish(obj, callback) {
      // Write the object to the separate file.
      var shortname = prop + '.json';
      var data = JSON.stringify(obj);
      var hash = _checkNewHash(shortname, data);
      if (!hash) {
        // No need to publish if the data is the same.
        return callback();
      }
      published[shortname] = true;
      // Update new object and call notifications.
      _updateObject(shortname, obj, hash);
      var fullname = path.join(folder, shortname);
      fs.writeFile(fullname, data, function (err) {
        if (err) {
          console.error('Failed to write file %s err:', fullname, err);
        }
        return callback(err);
      });
    }
function _publish ( obj , callback ) { // Write the object to the separate file.
 var shortname = prop + '.json' ; var data = JSON . stringify ( obj ) ; var hash = _checkNewHash ( shortname , data ) ; if ( ! hash ) { // No need to publish if the data is the same.
 return callback ( ) ; } published [ shortname ] = true ; // Update new object and call notifications.
 _updateObject ( shortname , obj , hash ) ; var fullname = path . join ( folder , shortname ) ; fs . writeFile ( fullname , data , function ( err ) { if ( err ) { console . error ( 'Failed to write file %s err:' , fullname , err ) ; } return callback ( err ) ; } ) ; }
Worker for publishing queue.
Worker for publishing queue .