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
to_all()
Alias for: broadcast
to_one()
Alias for: send

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