class ProxyService::Worker

Attributes

message[RW]
ready[W]

Public Class Methods

stomp() click to toggle source
# File lib/proxy_service/worker.rb, line 8
def self.stomp
  QueueWorker.stomp
end

Public Instance Methods

call(message) click to toggle source
# File lib/proxy_service/worker.rb, line 12
def call(message)
  @message = message
  @ready = true
end
ready?() click to toggle source
# File lib/proxy_service/worker.rb, line 17
def ready?
  !!@ready
end
release(proxy, is_blocked) click to toggle source
# File lib/proxy_service/worker.rb, line 21
def release(proxy, is_blocked)
  ack(message)
  unsubscribe
  publish(proxy) unless is_blocked
  close
end