Sha256: 93725aca38f40a9d78aafe43a9fe9d2784861f87542a2aecc23723b39c2110f2
Contents?: true
Size: 1.4 KB
Versions: 39
Compression:
Stored size: 1.4 KB
Contents
# frozen_string_literal: true
# :reek:UtilityFunction
module RubyRabbitmqJanus
module Janus
module Concurrencies
# Manage message used for keepalive thread
#
# @attribute [r] instance
# @return [String] ID to Janus Instance
class KeepaliveMessage
attr_reader :instance
def initialize(instance)
@instance = instance.id
end
def session
Janus::Messages::Standard.new('base::create', param_instance)
end
def response_session(message)
RubyRabbitmqJanus::Janus::Responses::Standard.new(message).session
end
def keepalive(session)
parameter = param_session(session)
Janus::Messages::Standard.new('base::keepalive', parameter)
end
def response_acknowledgement(message)
RubyRabbitmqJanus::Janus::Responses::Standard.new(message).error?
end
def destroy(session)
parameter = param_session(session)
Janus::Messages::Standard.new('base::destroy', parameter)
end
def response_destroy(message)
RubyRabbitmqJanus::Janus::Responses::Standard.new(message)
end
private
def param_instance
{ 'instance' => @instance }
end
def param_session(session)
{ 'session_id' => session }.merge(param_instance)
end
end
end
end
end
Version data entries
39 entries across 39 versions & 1 rubygems