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