const gearman = require('gearman')
let client = gearman("localhost", 4730 , {timeout: 3000})
client.on('timeout', function() {
console.log('Timeout occurred')
client.close()
})
client.on('WORK_COMPLETE', function(job) {
console.log('job completed, result:', job.payload.toString())
client.close()
})
client.connect(function() {
client.submitJob('upper', 'Hello, World!')
})
const gearman = require('gearman')
let worker = gearman('127.0.0.1', 4730)
worker.on('JOB_ASSIGN', function(job) {
console.log(job.func_name + ' job assigned to this worker')
let result = job.payload.toString().toUpperCase()
worker.sendWorkComplete(job.handle, result)
worker.preSleep()
});
worker.on('NOOP', function() { worker.grabJob() })
worker.connect(function(){
worker.addFunction('upper')
worker.preSleep()
});