nkeyes/philotic

View on GitHub
examples/subscribing/anonymous_queue.rb

Summary

Maintainability
A
0 mins
Test Coverage
#!/usr/bin/env ruby
$:.unshift File.expand_path('../../../lib', __FILE__)
$stdout.sync = true

require 'philotic'
require 'awesome_print'

Philotic.config.load_file(File.join(File.dirname(__FILE__), '../../', 'Philotic.yml.example'))

Philotic.subscribe(philotic_firehose: true) do |message|
  ap message.attributes
end

Philotic.subscriber.endure