class Skein::Client::Publisher
Public Class Methods
new(exchange_name, type: nil, durable: nil, connection: nil, context: nil)
click to toggle source
Instance Methods =====================================================¶ ↑
Calls superclass method
Skein::Connected::new
# File lib/skein/client/publisher.rb, line 4 def initialize(exchange_name, type: nil, durable: nil, connection: nil, context: nil) super(connection: connection, context: context) @queue = self.channel.send(type || :topic, exchange_name, durable: durable) end
Public Instance Methods
close(delete_queue: false)
click to toggle source
Calls superclass method
Skein::Connected#close
# File lib/skein/client/publisher.rb, line 15 def close(delete_queue: false) if (delete_queue) @queue.delete end super() end
publish!(message, routing_key = nil)
click to toggle source
# File lib/skein/client/publisher.rb, line 10 def publish!(message, routing_key = nil) @queue.publish(JSON.dump(message), routing_key: routing_key) end
Also aliased as: <<