kue-stream-client.js

'use strict';

var net = require('net');
var kue = require('kue');

var app = {};
app.$queue = kue.createQueue();

var job = app.$queue.create('stream-demo').save();

job.on('complete', function(socket) {
  console.log('Stream init...');
  
  var client = net.connect({
    path: socket
  }, function() {
    client.on('data', function(buffer) {
      console.log(buffer.toString());
    });
  });
  
});