Sha256: b916521f87ada78159d51ff18911d6748a1039524c75031c38a735eb132d59e5
Contents?: true
Size: 476 Bytes
Versions: 24
Compression:
Stored size: 476 Bytes
Contents
#!/usr/bin/env ruby
# encoding: utf-8
require "bundler"
Bundler.setup
Bundler.require(:default)
$LOAD_PATH.unshift(File.expand_path("../../../lib", __FILE__))
require "amq/client/adapters/socket"
AMQ::Client::SocketClient.connect(:host => "localhost") do |client|
# Socket API is synchronous, so we don't need any callback here:
tasks = client.queue("tasks", 1)
tasks.consume do |headers, message| # TODO: this is async, we need to use a loop
puts ""
end
end
Version data entries
24 entries across 24 versions & 1 rubygems