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