Sha256: f84cdaaa69a06e1ba47b6abf90d18c07bbcabce9e48da99ca7cff82fb654bd2d
Contents?: true
Size: 1.32 KB
Versions: 15
Compression:
Stored size: 1.32 KB
Contents
module Carrot::AMQP
class Exchange
attr_reader :server, :type, :name, :opts, :key, :carrot
def initialize(carrot, type, name, opts = {})
@server, @type, @name, @opts = carrot.server, type, name, opts
@key = opts[:key]
@carrot = carrot
unless name == "amq.#{type}" or name == ''
server.send_frame(
Protocol::Exchange::Declare.new(
{ :exchange => name, :type => type, :nowait => true }.merge(opts)
)
)
end
end
attr_reader :name, :type, :key
def publish(data, opts = {})
out = []
out << Protocol::Basic::Publish.new(
{ :exchange => name, :routing_key => opts.delete(:key) || key }.merge(opts)
)
data = data.to_s
out << Protocol::Header.new(
Protocol::Basic,
data.length, {
:content_type => 'application/octet-stream',
:delivery_mode => (opts.delete(:persistent) ? 2 : 1),
:priority => 0
}.merge(opts)
)
out << Frame::Body.new(data)
server.send_frame(*out)
end
def delete(opts = {})
server.send_frame(
Protocol::Exchange::Delete.new({ :exchange => name, :nowait => true }.merge(opts))
)
carrot.exchanges.delete(name)
end
def reset
initialize(server, type, name, opts)
end
end
end
Version data entries
15 entries across 15 versions & 6 rubygems