kennethkalmer

# multithreaded daemon example
#
#
#   daemon_kit foo
#

# Two classes that do the work, they live in lib/

# lib/foo.rb
class Foo

kennethkalmer

function(doc) {
  if(doc.type && doc.type == 'Email' && doc.unread == '1') {
    emit( doc.recipient, 1 )
  }
}

kennethkalmer

require 'rubygems'
require 'mq'

Signal.trap('INT') { AMQP.stop { EM.stop } }
Signal.trap('TERM') { AMQP.stop { EM.stop } }

AMQP.start do

  amq = MQ.new
  c1 = 0

kennethkalmer

DaemonKit::AMQP.run do
  # Inside this block we're running inside the reactor setup by the
  # amqp gem. Any code in the examples (from the gem) would work just
  # fine here.

  MQ.prefetch(10)

  # Uncomment this for connection keep-alive
  AMQP.conn.connection_status do |status|
    DaemonKit.logger.debug("AMQP connection status changed: #{status}")

kennethkalmer

require 'rubygems'
require 'mq'

AMQP.start do
  1000.times { |i| MQ.queue('A').publish("A #{i}") }
  1000.times { |i| MQ.queue('B').publish("B #{i}") }

  amq = MQ.new
  amq.queue('A').subscribe do |msg|
    p [ Time.now, msg ]

kennethkalmer

    # Ensure the AMQP connection is started
    def start!
      return if started?

      Thread.main[:ruote_amqp_connection] = Thread.new do
        Thread.abort_on_exception = true
        AMQP.start { RuoteAMQP.started! }
      end

      sleep 0.001 until RuoteAMQP.started?

kennethkalmer

require 'rubygems'
require 'activerecord'

$:.unshift('lib')
require 'state_machine'

ActiveRecord::Base.establish_connection({
  :adapter => 'mysql',
  :database => 'test',
  :username => 'root'

kennethkalmer

# Pseudo class
class SearchResult < ActiveRecord::Base
  has_no_table

  class << self
 
    def has_many( klass )
      # This is almost definitely wrong, but the idea is here
      define_method( klass.name.tableize ) do
        klass.for_search_term( self.id )

kennethkalmer

var proc_rep = ["define",{"name":"foo"},[["sequence",{},[["participant",{"activity":"Foo","ref":"nada"},[]]]]]];
4 FluoCan.renderFlow( 'fluo', proc_rep, { 'workitems' : ['0_0_0'] } );
5 FluoCan.crop('fluo'); 

kennethkalmer

require 'blather'