class Qpid::Proton::Handler::MessagingHandler
@deprecated use {Qpid::Proton::MessagingHandler}
Attributes
options[R]
@return [Hash] handler options, see {#initialize}
Public Class Methods
new(*args)
click to toggle source
@overload initialize(opts)
Create a {MessagingHandler} with options +opts+ @option opts [Integer] :prefetch (10) The number of messages to fetch in advance, 0 disables prefetch. @option opts [Boolean] :auto_accept (true) If true, incoming messages are accepted automatically after {#on_message}. If false, the application can accept, reject or release the message by calling methods on {Delivery} when the message has been processed. @option opts [Boolean] :auto_settle (true) If true, outgoing messages are settled automatically when the remote peer settles. If false, the application must call {Delivery#settle} explicitly. @option opts [Boolean] :auto_open (true) If true, incoming connections are opened automatically. If false, the application must call {Connection#open} to open incoming connections. @option opts [Boolean] :auto_close (true) If true, respond to a remote close automatically with a local close. If false, the application must call {Connection#close} to finish closing connections. @option opts [Boolean] :peer_close_is_error (false) If true, and the remote peer closes the connection without an error condition, the set the local error condition {Condition}("error", "unexpected peer close")
@overload initialize(prefetch=10, auto_accept=true, auto_settle=true, peer_close_is_error=false) @deprecated use +initialize(opts)+ overload
# File lib/handler/messaging_handler.rb, line 53 def initialize(*args) deprecated MessagingHandler, Qpid::Proton::MessagingHandler @options = {} if args.size == 1 && args[0].is_a?(Hash) @options.replace(args[0]) else # Fill options from deprecated fixed arguments [:prefetch, :auto_accept, :auto_settle, :peer_close_is_error].each do |k| opts[k] = args.shift unless args.empty? end end # NOTE: the options are processed by {Handler::Adapater} end
Public Instance Methods
proton_adapter_class()
click to toggle source
@private
# File lib/handler/messaging_handler.rb, line 27 def proton_adapter_class() Handler::ReactorMessagingAdapter; end