A TorqueBox service that consumes from a queue.

service_service.rb

class ServiceService

  def initialize(options)
    @queue = TorqueBox::Messaging::Queue.new( '/queues/service_request' )
    @running = true
  end

  def start()
    Thread.new do
      while @running
        request = @queue.receive( :timeout => 5000 )
        if request && @running
          puts request.inspect
        end
      end
    end
  end

  def stop()
    @running = false
  end
end