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 35
def initialize
  @supervisor = DispatcherSupervisor.spawn(name: 'RestartingSupervisor', args: [])
  @reference = @supervisor.ask!(:dispatcher_reference)
end

Public Instance Methods

done(uuid) click to toggle source
# File lib/smart_proxy_remote_execution_ssh/mqtt/dispatcher.rb, line 52
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 40
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 48
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 44
def running(uuid)
  reference.tell([:running, uuid])
end