class Proxy::RemoteExecution::Ssh::MQTT::Dispatcher

Attributes

reference[R]

Public Class Methods

new() click to toggle source
# File lib/smart_proxy_remote_execution_ssh/mqtt/dispatcher.rb, line 9
def initialize
  limit = Proxy::RemoteExecution::Ssh::Plugin.settings[:mqtt_rate_limit]
  @reference = DispatcherActor.spawn('MQTT dispatcher',
                                     Proxy::Dynflow::Core.world.clock,
                                     limit)
end

Public Instance Methods

done(uuid) click to toggle source
# File lib/smart_proxy_remote_execution_ssh/mqtt/dispatcher.rb, line 28
def done(uuid)
  reference.tell([:done, uuid])
end
new(uuid, topic, payload) click to toggle source
# File lib/smart_proxy_remote_execution_ssh/mqtt/dispatcher.rb, line 16
def new(uuid, topic, payload)
  reference.tell([:new, uuid, topic, payload])
end
resend(uuid) click to toggle source
# File lib/smart_proxy_remote_execution_ssh/mqtt/dispatcher.rb, line 24
def resend(uuid)
  reference.tell([:resend, uuid])
end
running(uuid) click to toggle source
# File lib/smart_proxy_remote_execution_ssh/mqtt/dispatcher.rb, line 20
def running(uuid)
  reference.tell([:running, uuid])
end