user = DataSift::User.new('my_username', 'my_api_key')
consumer = user.getConsumer(DataSift::StreamConsumer::TYPE_HTTP, 'my_stream' )
consumer.consume( true ) do |interaction|
    puts interaction['interaction']['content']
end

Kernel.at_exit do
    consumer.disconnect
end