class Rack::App::Worker::ClientProxy
Public Class Methods
new(name)
click to toggle source
# File lib/rack/app/worker/client_proxy.rb, line 5 def initialize(name) @name = name end
Public Instance Methods
broadcast()
click to toggle source
# File lib/rack/app/worker/client_proxy.rb, line 15 def broadcast Rack::App::Worker::ClientProxy::Wrapper.new(rabbitmq.broadcast_exchange(@name)) end
Also aliased as: to_all
send()
click to toggle source
# File lib/rack/app/worker/client_proxy.rb, line 9 def send Rack::App::Worker::ClientProxy::Wrapper.new(rabbitmq.send_exchange(@name)) end
Also aliased as: to_one
Protected Instance Methods
rabbitmq()
click to toggle source
# File lib/rack/app/worker/client_proxy.rb, line 23 def rabbitmq @rabbitmq ||= Rack::App::Worker::RabbitMQ.new end