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

<<(message, routing_key = nil)
Alias for: publish!
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: <<