class RubyRabbitmqJanus::RRJTaskAdmin

# RubyRabbitmqJanus - RRJTaskAdmin

Used wit sidekiq/console/CI execution for admin queue in Janus gateway

Public Instance Methods

admin_endpoint(options = {}) { |transaction| ... } click to toggle source

Create a transaction between Apps and Janus

This transaction is sending to admin/monitor API.

@params [Hash] options @options [String] :instance (mandatory id cluster is enabled) @options [Integer] :session_id @options [Hash] :replace @options [Hash] :add

@example List sessions

options = { 'instance' => 42 }
@rrj.handle_endpoint_private(options) do |transaction|
  transaction.publish_message('admin::list_sessions', options)
end

@example List handles

options = { 'instance' => 42, 'session_id' => 71984735765 }
@rrj.handle_endpoint_private(options) do |transaction|
  transaction.publish_message('admin::list_handles', options)
end

@since 2.7.0

# File lib/rrj/task_admin.rb, line 36
def admin_endpoint(options = {})
  transaction = Janus::Transactions::Admin.new(options)
  transaction.connect { yield(transaction) }
end