class Qpid::Proton::Reactor::Container

@deprecated use {Qpid::Proton::Container}

Public Class Methods

new(handlers, opts=nil) click to toggle source

@deprecated use {Qpid::Proton::Container}

Calls superclass method Qpid::Proton::Container::new
# File lib/reactor/container.rb, line 32
def initialize(handlers, opts=nil)
  deprecated Qpid::Proton::Reactor::Container, Qpid::Proton::Container
  h = handlers || (opts && opts[:global_handler]) || Handler::ReactorMessagingAdapter.new(nil)
  id = opts && opts[:container_id]
  super(h, id)
end

Public Instance Methods

connect(opts=nil) click to toggle source
Calls superclass method Qpid::Proton::Container#connect
# File lib/reactor/container.rb, line 42
def connect(opts=nil)
  url = opts && (opts[:url] || opts[:address])
  raise ::ArgumentError.new, "no :url or :address option provided" unless url
  super(url, opts)
end
Also aliased as: super_connect
create_receiver(context, opts=nil) click to toggle source
# File lib/reactor/container.rb, line 59
def create_receiver(context, opts=nil)
  c = context if context.is_a? Qpid::Proton::Connection
  unless c
    url = Qpid::Proton::uri context
    c = super_connect(url, opts)
    opts ||= {}
    opts[:source] ||= url.amqp_address
  end
  c.open_receiver opts
end
create_sender(context, opts=nil) click to toggle source
# File lib/reactor/container.rb, line 48
def create_sender(context, opts=nil)
  c = context if context.is_a? Qpid::Proton::Connection
  unless c
    url = Qpid::Proton::uri context
    c = super_connect(url, opts)
    opts ||= {}
    opts[:target] ||= url.amqp_address
  end
  c.open_sender opts
end
listen(url, ssl_domain = nil) click to toggle source
Calls superclass method Qpid::Proton::Container#listen
# File lib/reactor/container.rb, line 70
def listen(url, ssl_domain = nil)
  # TODO aconway 2017-11-29: ssl_domain
  super(url)
end
super_connect(opts=nil)
Alias for: connect