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