TorqueBox.configure do
  web do
    ...
    context "/poorsmatic"
    ...
  end
end

class AService
  def initialize(credentials = {})
  end

  def start
  end

  def stop
  end
end

require 'twitter4j4r'

class TwitterService
  ...
  def initialize(credentials = {})

    @terms = []

    @client = Twitter4j4r::Client.new(
        :consumer_key     => credentials['consumer_key'],
        :consumer_secret  => credentials['consumer_secret'],
        :access_token     => credentials['access_token'],
        :access_secret    => credentials['access_secret']
    )

    @client.on_exception do |exception|
      puts "An error occured while reading the stream: #{exception.message}"
    end
  end

  def start
    @client.track(*@terms) do |status, client|
    end
  end

  def stop
    @client.stop
  end
end

TorqueBox.configure do
  ...
  service TwitterService do
    name 'twitter-service'
    config do
      consumer_key 'Consumer key'
      consumer_secret 'Consumer secret'
      access_token 'Access token'
      access_secret 'Access token secret'
    end
  end
end

require 'torquebox'
require 'sinatra'
require 'haml'
require 'models/term'

class Poorsmatic < Sinatra::Base
  include TorqueBox::Injectors
  ...
  helpers do
    def terms_changed
      terms = []

      Term.all.each {|t| terms << t.term}

      topic = fetch('/topics/terms')

      topic.publish(terms)
    end
  end
  ...
  post '/terms' do

    term = Term.new(:term => params[:term])

    TorqueBox.transaction do
      if term.save
        terms_changed
      else
        session[:errors] = []
        term.errors.each {|e| session[:errors] << e.first }
      end
    end

    redirect to('/terms')
  end

  delete '/term/:id' do
    TorqueBox.transaction do
      Term.get(params[:id]).destroy
      terms_changed
    end

    redirect to('/terms')
  end
  ...
end