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