Sha256: d86ea170c716a97cb027434d110fdd88d295f2983f7cc86f07a7beaaf2a102af

Contents?: true

Size: 995 Bytes

Versions: 1

Compression:

Stored size: 995 Bytes

Contents

# Cloudst Example: Sandwich Client
# 
# This example demonstrates dispatching a job to the worker and receiving event callbacks.
# 
# Be sure to update the Cloudist connection settings if they differ from defaults:
# user: guest
# pass: guest
# port: 5672
# host: localhost
# vhost: /
#
$:.unshift File.dirname(__FILE__) + '/../lib'
require "rubygems"
require "cloudist"

Cloudist.signal_trap!

Cloudist.start {
  
  log.info("Dispatching sandwich making job...")
  enqueue('make.sandwich', {:bread => 'white'})
  # enqueue('make.sandwich', {:bread => 'brown'})
  
  # Listen to all sandwich jobs
  listen('make.sandwich') {
    everything {
      Cloudist.log.info("Job ID: #{job_id}")
    }
    
    progress {
      Cloudist.log.info("Progress: #{data[:progress]}")
    }
    
    event('started') {
      Cloudist.log.info("Started making sandwich at #{Time.now.to_s}")
    }
    
    event('finished'){
      Cloudist.log.info("Finished making sandwich at #{Time.now.to_s}")
    }
  }
  
}

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
cloudist-0.1.2 examples/sandwich_client.rb