salesforce_streaming_api_test.rb

require 'restforce'
require 'faye'
require 'pry'

Restforce.log = true

client = Restforce.new username: '**********************************',
  password:       '************************',
  security_token: '************************',
  client_id:      '*************************************************************************************',
  client_secret:  '******************'

name = "AllAccounts"
puts 'Topic: ' + name

begin
  p client.authenticate!
  puts "authenticated"
  puts

  EM.run do
    client.subscribe(name) do |message|
      puts message.inspect
    end
  end

rescue Exception => e
  p e
  puts "Could not authenticate. Not listening for streaming events."
end